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

关于线程间通信

时间:2015-07-28 12:47:43      阅读:134      评论:0      收藏:0      [点我收藏+]

标签:

  在开发中遇到过这样的需求,主线程中开启多个子线程来处理数据以提高效率,待所有的子线程执行完成任务后,主线程继续完成后续的操作。一番思考后,思路出来了,我的做法是定义一个全局整型的静态变量,每个子线程完成任务后变量加1。主线程里有一个while死循环,每次循环判断这个变量的值,如果值为开启的线程数则表示所有子线程已经完成了任务,然后跳出循环继续执行后续的操作。逻辑上来看这是没有任何问题的,于是很快就完成了编码运行测试。结果自然和预料中的一样没啥问题。

  运行过程中发现cpu使用率很高,如果执行的时间过长总能感觉到风扇转的很厉害,很担心会吧自己的本本烧坏。于是想到了优化代码,可是如何下手从哪里下手呢,思考良久想到了一个很二的办法,在循环里加了句Thread.Slee()。这样,每次循环后让主线程睡眠一段时间的方法来降低循环cpu的高使用率。这样优化代码,运行了一段时间。但也没和之前进行过比较,效率是高了还是低了无所知晓,心里总在嘀咕这样的代码看着很是别扭。尽管没有几行的代码,反正看着就是不舒服、不顺眼,于是又有了优化的念头。这次的优化不再是自己苦思冥想,应该百度一下,看人家是如何实现的。

  一番搜索后,终于找到了关键字“ManualResetEvent”,然后就是MSDN查阅相关文档,以下为练习的代码

using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading;

namespace ManualResetEventTest
{
    class Program
    {
        static void Main(string[] args)
        {
            ManualResetEventContext[] contexts = new ManualResetEventContext[5];
            ManualResetEvent[] manualResetEvents = new ManualResetEvent[5];
            for (int i = 0; i < 5; i++)
            {
                ManualResetEvent e = new ManualResetEvent(false);
                manualResetEvents[i] = e;
                contexts[i] = new ManualResetEventContext(e, doSomeThing) { ID = i };
                ThreadPool.QueueUserWorkItem(contexts[i].Invoke, contexts[i]);
            }
            WaitHandle.WaitAll(manualResetEvents);
            Console.WriteLine("所有子线程执行完成");
            Console.Read();
        }

        static void doSomeThing(object state)
        {
            ManualResetEventContext context = state as ManualResetEventContext;
            //do...
            Thread.Sleep(1000*60);
            Console.WriteLine(string.Format("第{0}个子线程执行完成", context.ID));
        }
    }

    public class ManualResetEventContext
    {
        public int ID { get; set; }
        public ManualResetEvent ManualResetEvent { get; set; }
        private WaitCallback _callback;

        public ManualResetEventContext(ManualResetEvent manualResetEvent, WaitCallback callback)
        {
            this.ManualResetEvent = manualResetEvent;
            this._callback = callback;
        }

        public void Invoke(object state)
        {
            try
            {
                _callback(state);
            }
            finally 
            {
                //子线程操作完成后必须调用此方法
                ManualResetEvent.Set();
            }
        }
    }
}
运行结果:
技术分享

  

关于线程间通信

标签:

原文地址:http://www.cnblogs.com/kaixiangbb/p/3706669.html

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