STPStartInfo stp = new STPStartInfo();//线程详细配置参数 stp.CallToPostExecute = CallToPostExecute.Always;//在这里选择总是回调 //当工作项执行完成后,是否释放工作项的参数,如果释放,参数对象必须实现IDisposable接口 stp.DisposeOfStateObjects = true; //当线程池中没有工作项时,闲置的线程等待时间,超过这个时间后,会释放掉这个闲置的线程,默认为60秒 // stp.IdleTimeout = 300;//300s //最大线程数,默认为25, //注意,由于windows的机制,所以一般最大线程最大设置成25, //如果设置成0的话,那么线程池将停止运行 stp.MaxWorkerThreads = 50;//15 thread //只在STP执行Action<...>与Func<...>两种任务时有效 //在执行工作项的过程中,是否把参数传递到WorkItem中去,用做IWorkItemResult接口取State时使用, //如果设置为false那么IWorkItemResult.State是取不到值的 //如果设置为true可以取到传入参数的数组 stp.FillStateWithArgs = true; //当工作项执行完毕后,默认的回调方法 stp.PostExecuteWorkItemCallback = delegate(IWorkItemResult wir) { this.BeginInvoke(updateTxt, "-----------------ok" + wir.Result + "\r\n"); }; //是否需要等待start方法后再执行工作项,?默认为true,当true状态时,STP必须执行Start方法,才会为线程分配工作项 stp.StartSuspended = true; stp.AreThreadsBackground = true; m_hThreadPool = new SmartThreadPool(stp);//声明一个线程池 foreach (int state in abc) { //IWorkItemResult resultCallback = m_hThreadPool.QueueWorkItem(new Amib.Threading.Func(IntDoSomeWork), state); //m_hThreadPool.QueueWorkItem( (obj) => // { // Thread.Sleep(3000); // this.BeginInvoke(updateTxt, "正在执行" + state.ToString() + "\r\n"); // string str = "正在执行" + state.ToString() + "\r\n"; // return state * state; // }, state); //this.BeginInvoke(updateTxt, resultCallback.Result.ToString() + "\r\n"); } m_hThreadPool.Start(); m_hThreadPool.WaitForIdle();//等待该实例下的所有结果返回 //MessageBox.Show(resultCallback.Result.ToString()); m_hThreadPool.Shutdown();