惯性聚合 高效追踪和阅读你感兴趣的博客、新闻、科技资讯
阅读原文 在惯性聚合中打开

推荐订阅源

Google DeepMind News
Google DeepMind News
D
Docker
Last Week in AI
Last Week in AI
WordPress大学
WordPress大学
月光博客
月光博客
小众软件
小众软件
量子位
V
Visual Studio Blog
H
Hackread – Cybersecurity News, Data Breaches, AI and More
T
Tailwind CSS Blog
Cyber Security Advisories - MS-ISAC
Cyber Security Advisories - MS-ISAC
罗磊的独立博客
博客园 - 叶小钗
美团技术团队
让小产品的独立变现更简单 - ezindie.com
让小产品的独立变现更简单 - ezindie.com
Apple Machine Learning Research
Apple Machine Learning Research
博客园 - 三生石上(FineUI控件)
博客园 - 聂微东
博客园 - 司徒正美
Microsoft Azure Blog
Microsoft Azure Blog
博客园 - Franky
Hugging Face - Blog
Hugging Face - Blog
GbyAI
GbyAI
C
Check Point Blog

博客园 - Goodspeed

几种常见的函数 Caesar cipher 遗传算法之背包问题 Transport scheme NOT recognized: [stomp] error running git Canvas 旋转的图片 canvas时钟 火箭起飞 让图标转起来 Tomcat启动脚本 Task中的异常处理 Parallel的陷阱 使用ThreadPool代替Thread 正确停止线程 线程同步中使用信号量AutoResetEvent 异步和多线程的区别 C#和.NET Framework的关系 为什么泛型不支持协变性? 可空值类型与值类型这间的转换
用Task代替TheadPool
Goodspeed · 2014-11-02 · via 博客园 - Goodspeed

TheadPool的问题

  1. 不支持线程的取消、完成、失败通知等交互性操作
  2. 不支持线程执行先后次序
using System;
using System.Diagnostics;
using System.Threading;
using System.Threading.Tasks;

namespace ConsoleApplication1
{
    class Program
    {
        static void Main(string[] args)
        {
            var p = new Program();
            p.Task();
            Console.ReadKey();
            p.Signal();
            Console.ReadKey();
        }

        CancellationTokenSource cts = new CancellationTokenSource();

        void Task()
        {
            var random = new Random();
            for (int i = 0; i < 100; i++)
            {
                var worker = new Task(() =>
                {
                    while (true)
                    {
                        if (random.Next(100) % 2 == 1)
                        {
                            if (cts.IsCancellationRequested)
                            {
                                break;    
                            }
                            
                        }
                        else
                        {
                            cts.Token.ThrowIfCancellationRequested(); //异常取消
                        }
                        Thread.Sleep(100);
                    }
                });
                worker.Start();
                worker.ContinueWith(task =>
                {
                    Console.WriteLine("IsCancele={0},IsCompleted={1},IsFaulted={2}", task.IsCanceled, task.IsCompleted, task.IsFaulted);
                });
            }

        }

        void Signal()
        {
            cts.Cancel();
        }
    }
}