C# 线程池的使用终止线程池中的队列

OStack程序员社区-中国程序员成长平台 › 门户 › 编程› Node.js›Node.js教程

原作者: [db:作者] 来自: [db:来源] 收藏邀请

C#的线程池使用起来还是非常简单的，这里记录一下。

根据http://blog.csdn.net/chen_zw/article/details/7939834里的描述这里记录一下C#线程池的特点

一个进程有且只能管理一个线程池。
线程池线程都是后台线程（即不会阻止进程的停止）
每个线程都使用默认堆栈大小，以默认的优先级运行，并处于多线程单元中。超过最大值的其他线程需要排队，但它们要等到其他线程完成后才启动。
在CLR 2.0 SP1之前的版本中，线程池中默认最大的线程数量 = 处理器数 * 25, CLR 2.0 SP1之后就变成了默认最大线程数量 = 处理器数 * 250，线程上限可以改变，通过使用ThreadPool.GetMax+Threads和ThreadPool.SetMaxThreads方法，可以获取和设置线程池的最大线程数。
默认情况下，每个处理器维持一个空闲线程，即默认最小线程数 = 处理器数。
当进程启动时，线程池并不会自动创建。当第一次将回调方法排入队列（比如调用ThreadPool.QueueUserWorkItem方法）时才会创建线程池。
在对一个工作项进行排队之后将无法取消它。
线程池中线程在完成任务后并不会自动销毁，它会以挂起的状态返回线程池，如果应用程序再次向线程池发出请求，那么这个挂起的线程将激活并执行任务，而不会创建新线程，这将节约了很多开销。只有线程达到最大线程数量，系统才会以一定的算法销毁回收线程。

在使用线程池的时候，需要初始化其状态

ManualResetEvent eventX = new ManualResetEvent(false);//表示线程池的状态 false代表非终结状态

根据https://www.cnblogs.com/tianboblog/p/5393444.html介绍：

当初始化为true时，为终止状态

static ManualResetEvent _mre = new ManualResetEvent(true);

当初始化为false时，为非终止状态

static ManualResetEvent _mre = new ManualResetEvent(false);
 
终止状态时WaitOne()允许线程访问下边的语句
非终止状态时WaitOne()阻塞线程，不允许线程访问下边的语句
把非终止状态改为终止状态用Set()方法
把终止状态改为非终止状态用Reset()方法
//按钮事件
private void btnBatchSend_Click(object sender, RoutedEventArgs e)
        {
eventX.Reset();
                ThreadPool.SetMinThreads(1, 1);//设置线程池在新请求预测中维护的空闲线程数
                ThreadPool.SetMaxThreads(10,10);//设置可以同时处于活动状态的线程池的最大请求数目
以上两句必须都有才行
//循环设置执行对象，
for (int i = 0; i < list.Count; i++)
                {
 ThreadPool.QueueUserWorkItem(tranSend, oj);//
}
eventX.WaitOne();//当是非终结状态时，会阻塞主线程
                eventX.Reset();//设置为非终结状态
}
worker.RunWorkerCompleted += (o, ea) =>
            {
                //sb.Append("主线程执行完毕");
                //this.txt_cansole.Text = sb.ToString();
                this.btnBatchCheck.IsEnabled = true;
                this.btnBatchSend.Visibility = Visibility.Visible;
                this.btnStopSend.Visibility = Visibility.Collapsed;
            };
            this.btnBatchCheck.IsEnabled = false;
            this.btnBatchSend.Visibility = Visibility.Collapsed;
            this.btnStopSend.Visibility = Visibility.Visible;
            worker.RunWorkerAsync();
 
//每个线程将会执行的任务
private void tranSend(object order)
        {
 Order s = order as Order;
//当是最后一个order 或者 用户点了停止按钮时
            if (s.IsLas || Break)
            {
                eventX.Set();//当点了停止按钮时，将线程池信号灯状态设置为终结状态这时会通知主线程继续往下执行
                return;
            }
//真正的执行任务代码
            s.SendMessage = ">>";
            s.ItemStatus = 1;       /
}
 
可以看出来熟练C#线程池的使用主要是控制好信号灯的状态，当主线程往下执行时，for循环里的代码会很快执行完毕，虽然最多只允许了十个线程同时活动，但十个之后的对象已经加入了队列，需要中断时，需要在执行任务里去自行判断。
if (s.IsLas || Break)
{
eventX.Set();//当点了停止按钮时，将线程池信号灯状态设置为终结状态这时会通知主线程继续往下执行
return;
}