c#自己实现线程池功能(二)

介绍

在上一篇c#自己实现线程池功能(一)中，我们基本实现了一个可以运行的程序，而不能真正的称作线程池。由于是上篇中的代码有个致命的bug那就是没有任务是并不是等待，而是疯狂的进行while循环，并试图lock任务链表，这样带来的问题的就是性能相当低下，程序反映速度很慢（当加入一个新任务后，要过很久这个job才开始运行）造成的原因就是刚才所说的。

为了解决这个问题我们就需要使用某种方法使得程序能够让进程同步。

方法一

使用信号量

我们为了减少对task任务的加锁操作，只有当task不为空时才进行试探。我们的信号量就代表的是任务表里面的数量，当s.WaitOne();成功后我们才开始加锁，并取出任务

while (flag && TaskQueue != null)
            {
                //等待任务
                ThreadPoolManager.s.WaitOne();
                //获取任务
                lock (TaskQueue)
                {
                    try
                    {
                        if (TaskQueue.Count > 0)
                            task = TaskQueue.Dequeue();
                        else
                            task = null;
                    }
                    catch (Exception)
                    {
                        task = null;
                    }
                    if (task == null)
                        continue;

在ThreadPoolManager类中加入两个变量

//由于采用信号量需要定义一个
        public int MaxJobNum = 1000;
        public static Semaphore s;

并在初始化这个类时 初始化信号量 s = new Semaphore(0, MaxJobNum);

vc商城(eshop)

采用目前业界最流行的模版编译系统，所有的页面都可以实现在线/离线修改，只需简单掌握HTML的知识，就可以轻松创建属于自己的个性化的专业用户界面，内建多语言包替换模块，独创的商品参数模版系统，强大的后台管理支持和数据备份功能

下载

这样就能够实现同步

下面给出一个测试类

static void Main(string[] args)
       {
           ThreadPoolManager tpm = new ThreadPoolManager(2);
 
           TestTask t1 = new TestTask("task1");
           TestTask t2 = new TestTask("task2");
           TestTask t3 = new TestTask("task3");
           TestTask t4 = new TestTask("task4");
           TestTask t5 = new TestTask("task5");
           TestTask t6 = new TestTask("task6");
           TestTask t7 = new TestTask("task7");
           TestTask t8 = new TestTask("task8");
           TestTask t9 = new TestTask("task9");
 
           tpm.AddTask(t1);
           tpm.AddTask(t2);
           tpm.AddTask(t3);
           tpm.AddTask(t4);
           tpm.AddTask(t5);
           tpm.AddTask(t6);
           tpm.AddTask(t7);
           tpm.AddTask(t8);
           tpm.AddTask(t9);
       }

喎�"/kf/ware/vc/" target="_blank" class="keylink">vcD4KPGgxPre9t6i2/jwvaDE+Cs7Sw8eyu8rH08PQxbrFwb+jrM7Sw8fKudPDQXV0b1Jlc2V0RXZlbnTAtMq1z9bNrLK9Cjxicj4KCrXa0ruyvaOs1NpUaHJlYWRQb29sTWFuYWdlcrP1yry7r8qxuvK0tL2o0ru49iAgbG9ja3MgPSBuZXcgQXV0b1Jlc2V0RXZlbnQoZmFsc2UpOwq1sUFkZFRhc2u1xMqxuvJsb2Nrcy5TZXQoKTvNqNaqtci0/bXEstnX96GjCsi7uvPO0sPHttRXb3JrVGhyZWFktcRydW66r8r91/bSu7j20KHQobXE0N64xAo8cHJlIGNsYXNzPQ=="brush:java;"> public void run() { while (flag && TaskQueue != null) { //等待任务 //ThreadPoolManager.sep.WaitOne(); //等待任务 while (TaskQueue.Count == 0 && flag) { try { ThreadPoolManager.locks.WaitOne(); } catch (Exception) { } } //获取任务 lock (TaskQueue) { try { task = TaskQueue.Dequeue(); } catch (Exception) { task = null; } if (task == null) continue; } try { task.SetEnd(false); task.StartTask(); } catch (Exception) { } try { if (!task.IsEnd()) { task.SetEnd(false); task.EndTask(); } } catch (Exception) { } }//end of while }只有当task列表的数量为0时我们才阻塞，直到AddTask的时候才继续下去 

 以上就是c#自己实现线程池功能(二)的内容，更多相关内容请关注PHP中文网（www.php.cn）！