码迷,mamicode.com
首页 > 编程语言 > 详细

c# 指定线程数的多线程操作

时间:2017-09-27 19:00:04      阅读:452      评论:0      收藏:0      [点我收藏+]

标签:tco   remove   建议   false   线程   waiting   cal   eth   round   

多线程操作一直用ThreadPool.QueueUserWorkItem比较多,今天想到用这个方式实现,控制并发线程的数量。

主要思路是:

  1.声明开启的线程数 int threadCount = 2;

  2.创建一个泛型集合List<TaskInfo>  workingList = new List<TaskInfo>(); 需要开启多少个线程,就从Queue里取几个taskInfo,添加到workingList,同时,把TaskInfo.IsBusy置为true.

  3.在子线程中,执行完成时,再把TaskInfo.IsBusy置为false.

  4.在主线程中,循环往workingList中放入TaskInfo 对象, 并通过判断TaskInfo.isBusy, 移除执行完成的TaskInfo对象。

代码如下,如有任何建议,还望不吝赐教。

public class TaskInfo
{
    public bool IsBusy { get; set; }

    public int ID { get; set; }
}

public class Test
{        
     public void Work(object obj)
    {
        var taskInfo = obj as TaskInfo;

     //Do something ... Thread.Sleep(
5000); taskInfo.IsBusy = false; } public void Test_MultyThread() { int threadCount = 2; Queue<TaskInfo> taskQueue = new Queue<TaskInfo>(); taskQueue.Enqueue(new TaskInfo() { ID = 1 }); taskQueue.Enqueue(new TaskInfo() { ID = 2 }); taskQueue.Enqueue(new TaskInfo() { ID = 3 }); taskQueue.Enqueue(new TaskInfo() { ID = 4 }); taskQueue.Enqueue(new TaskInfo() { ID = 5 }); List<TaskInfo> workingList = new List<TaskInfo>(); while (taskQueue.Count > 0) { if (workingList.Count < threadCount) { var taskInfo = taskQueue.Dequeue(); taskInfo.IsBusy = true; workingList.Add(taskInfo); Console.WriteLine("Processing ID: {0}", taskInfo.ID); ThreadPool.QueueUserWorkItem(new WaitCallback(Work), taskInfo); } else { if (workingList.Any(x => !x.IsBusy)) { workingList.RemoveAll(x => !x.IsBusy); } else { Console.ForegroundColor = ConsoleColor.Yellow; Console.WriteLine("==> Waiting for free thread ..."); Console.ResetColor(); Thread.Sleep(1000); } } } } }

 

c# 指定线程数的多线程操作

标签:tco   remove   建议   false   线程   waiting   cal   eth   round   

原文地址:http://www.cnblogs.com/RyanHan/p/7602722.html

(0)
(0)
   
举报
评论 一句话评论(0
登录后才能评论!
© 2014 mamicode.com 版权所有  联系我们:gaon5@hotmail.com
迷上了代码!