suspendedstpstartexample.cs

来自「线程池实例,1.1版本,用于代替.net自带线程池」· CS 代码 · 共 37 行

using System;
using Amib.Threading;

namespace Examples
{
	public class SuspendedSTPStartExample
	{
		public void DoWork(object [] states) 
		{ 
			STPStartInfo stpStartInfo = new STPStartInfo();
			stpStartInfo.StartSuspended = true;

			SmartThreadPool smartThreadPool = new SmartThreadPool(stpStartInfo);

			foreach(object state in states)
			{
				smartThreadPool.QueueWorkItem(new 
					WorkItemCallback(this.DoSomeWork), state);
			}

			// Start working on the work items in the queue
			smartThreadPool.Start();

			// Wait for the completion of all work items
			smartThreadPool.WaitForIdle();

			smartThreadPool.Shutdown();
		} 

		private object DoSomeWork(object state)
		{ 
			// Do the work
			return null;
		}
	}
}