美文网首页
C#中如何串行执行所有线程

C#中如何串行执行所有线程

作者: zhongwcool | 来源:发表于2020-05-11 19:02 被阅读0次

为建立中文知识库加块砖        ——中科大胡不归

0. 前言

第一次在技术群提出这个问题,大佬们一脸懵逼,既然你要串行执行,为什么不单线程。其实就是由于很多场景需要封装的业务逻辑,并依赖线程,比如顺序写日志文件。
当然这是我现阶段粗浅水平所能想到的实现方法,希望以后能接触到更广大的世界,能嘲笑今天的自己。

1. 实现原理

AutoResetEvent

依赖AutoResetEvent的信号机制实现“串行”。
对象方法:

  • Set表示设置为有信号状态,这时调用WaitOne的线程将继续执行;
  • Reset表示设置为无信号状态,这时调用WaitOne的线程将阻塞;
  • WaitOne表示在无信号状态时阻塞当前线程,也就是说WaitOne只有在无信号状态下才会阻塞线程。
    因为AutoResetEvent调用Set后会在第一个调用WaitOne后,自动将信号置为无信号状态,导致其他调用WaitOne的线程继续阻塞。

Queue

使用Queue的“先进先出”特性实现“顺序”。
最早使用ThreadPool,但是不能控制线程顺序被唤醒。也可能是未得其法,希望有大神看到能指正用法。

2. 代码

正文只贴关键代码:

public partial class MainWindow
    {
        private readonly Queue<CookieTask> _threadQueue = new Queue<CookieTask>();
        private readonly AutoResetEvent _autoResetEvent = new AutoResetEvent(true);
        private int _count = 10;

        public MainWindow()
        {
            InitializeComponent();
            
            var task  = new Thread(SerialService);
            task.Start();
        }

        private void SerialService()
        {
            while (true)
            {
                if (_threadQueue.Count > 0)
                {
                    var tt = _threadQueue.Dequeue();
                    tt.Worker.Start(tt.Data);
                }

                Thread.Sleep(500);
            }
        }

        private void Button_OnClick(object sender, RoutedEventArgs e)
        {
            for (var i = 0; i < 100; i++)
            {
                var tt1 = new Thread(DemoTask);
                _threadQueue.Enqueue(new CookieTask(tt1, _count--));
                if (_count <= 0)
                {
                    _count = 10;
                }
            }
        }

        private void DemoTask(object seconds)
        {
            _autoResetEvent.WaitOne();

            int times = int.Parse(seconds.ToString());
            while (times-- > 0) 
            {
                Debug.Write(int.Parse(seconds.ToString()) + " ");
                Thread.Sleep(10);
            }
            Debug.WriteLine("");

            _autoResetEvent.Set();
        }
    }

完整工程
我们在初始化AutoResetEvent对象时,将初始为true即表示有信号状态,所以第一个提交的DemoTask中的WaitOne能拿到信号。
AutoResetEvent在第一个调用WaitOne后,自动将信号置为无信号状态导致其他调用WaitOne阻塞。

参考文章:

  1. WPF下多线程的使用方法
  2. C#线程控制ManualResetEvent和AutoResetEvent

相关文章

  • C#中如何串行执行所有线程

    为建立中文知识库加块砖——中科大胡不归 0. 前言 第一次在技术群提出这个问题,大佬们一脸懵逼,既然你要串行执行,...

  • 线程串行并行调度实现

    线程串行并行调度实现 问题描述 问题描述:线程A、B、C并行执行,然后和线程D串行执行,如何实现。 问题具体化:现...

  • iOS-GCDDemo

    1.同步+串行 1).所有任务都是在当前线程(主线程)中执行的,并没有开启新的线程(同步执行不具备开启新线程的能力...

  • 多线程

    GCD 创建串行队列,会开启1个线程,依次执行所有的任务 并行队列,会创建N个线程,同时执行多个任务 往界面中添加...

  • GCD线程方面的总结

    /// 串行队列+异步 == 只会开启一个线程,且队列中所有的任务都是在这个线程中执行 NSLog(@"star...

  • 多线程详解-NSThread、GCD、NSOperation

    线程的串行 一个线程中任务的执行是串行的如果要再一个线程中执行多个任务,那么只能一个一个的按顺序执行这些任务也就是...

  • GCD多线程—串行、并行、同步、异步线程数目

    一、串行队列 1、同步运行 结论:串行队列-同步运行,不会开启新的线程,线程函数会在创建队列所在的线程中执行(如上...

  • iOS开发-队列和同步异步执行的结果分析

    多线程中的队列有:串行队列,并发队列,全局队列(并发),主队列(串行)。 执行的方法有:同步执行和异步执行。 提到...

  • iOS 多线程-CGD

    串行队列同步执行,不开启新线程,任务按顺序执行 串行队列异步执行,会开启新线程(1个),任务按照顺序执行 并行队列...

  • iOSIN-GCD

    队列和同步异步 区别并行队列串行队列主队列同步(sync)没有开启新线程,串行执行任务没有开启新线程,串行执行任务...

网友评论

      本文标题:C#中如何串行执行所有线程

      本文链接:https://www.haomeiwen.com/subject/zplpnhtx.html