Barrier 任务并行库使用小计

Barrier  是一个对象,它可以在并行操作中的所有任务都达到相应的关卡之前,阻止各个任务继续执行。 如果并行操作是分阶段执行的,并且每一阶段要求各任务之间进行同步,则可以使用该对象。


Barrier其实就是将多个任务同步,而同步需要一个屏障或者是关卡,那么其方法SignalAndWait()就是屏障的作用

using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading;
using System.Threading.Tasks;
namespace BarrierApplication
{
    class Program
    {
        static Barrier gate;
        static void Main(string[] args)
        {
            try
            {
                ToStationWorkTyp1();
                ToStationWorkTyp2();
            }
            catch (Exception ex)
            {
                Console.WriteLine(string.Format("Exception Message:{0}", ex.Message.Trim()));
            }
            finally
            {
                Console.ReadKey(true);
            }
        }
        #region 方法1
        private static void ToStationWorkTyp1()
        {
            gate = new Barrier(3);
            Task _taskA = Task.Factory.StartNew(() => ToStation("PersonA", 2));
            Task _taskB = Task.Factory.StartNew(() => ToStation("PersonB", 3));
            Task _taskC = Task.Factory.StartNew(() => ToStation("PersonC", 5));
            Task.WaitAll(_taskA, _taskB, _taskC);
        }
        private static void ToStation(string name, int costTime)
        {
            Console.WriteLine(string.Format("[{0}]在去火车站路上.....,花费{1}小时.", name, costTime));
            Thread.Sleep(new TimeSpan(0, 0, costTime));
            Console.WriteLine(string.Format("[{0}]到达火车站,正在安检等候火车.....", name));
            gate.SignalAndWait();
            Console.WriteLine(string.Format("[{0}]乘坐火车离开.....", name));
        }
        #endregion
        #region 方法2
        private static void ToStationWorkTyp2()
        {
            gate = new Barrier(3);
            Task _taskA = Task.Factory.StartNew(() =>
            {
                OnRoading("personA", 2);
                OnStationing("personA");
                OnTraining("personA");
            });
            Task _taskB = Task.Factory.StartNew(() =>
            {
                OnRoading("personB", 5);
                OnStationing("personB");
                OnTraining("personB");
            });
            Task _taskC = Task.Factory.StartNew(() =>
            {
                OnRoading("personC", 3);
                OnStationing("personC");
                OnTraining("personC");
            });
            Task.WaitAll(_taskA, _taskB, _taskC);
        }
        private static void OnTraining(string name)
        {
            Console.WriteLine(string.Format("[{0}]乘坐火车离开.....", name));
        }
        private static void OnStationing(string name)
        {
            Console.WriteLine(string.Format("[{0}]到达火车站,正在安检等候火车.....", name));
            gate.SignalAndWait();
        }
        private static void OnRoading(string name, int costTime)
        {
            Console.WriteLine(string.Format("[{0}]在去火车站路上.....,花费{1}小时.", name, costTime));
            Thread.Sleep(new TimeSpan(0, 0, costTime));
        }
        #endregion
    }
}


知识共享许可协议
《Barrier 任务并行库使用小计》常伟华 创作。
采用 知识共享 署名-相同方式共享 3.0 中国大陆 许可协议进行许可。
  • 多说评论
  • 签名
  • 新浪微博
  • 默认评论
  • Tab Header 5

0 条评论 / 点击此处发表评论

Tab Content 5

开发技术


开发平台和工具

sitemap     149.06ms