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

推荐订阅源

量子位
D
DataBreaches.Net
Microsoft Security Blog
Microsoft Security Blog
V
Visual Studio Blog
GbyAI
GbyAI
美团技术团队
云风的 BLOG
云风的 BLOG
大猫的无限游戏
大猫的无限游戏
小众软件
小众软件
博客园 - 叶小钗
Engineering at Meta
Engineering at Meta
博客园 - 三生石上(FineUI控件)
N
Netflix TechBlog - Medium
奇客Solidot–传递最新科技情报
奇客Solidot–传递最新科技情报
G
Google Developers Blog
博客园 - 【当耐特】
OSCHINA 社区最新新闻
OSCHINA 社区最新新闻
宝玉的分享
宝玉的分享
阮一峰的网络日志
阮一峰的网络日志
T
The Blog of Author Tim Ferriss
Y
Y Combinator Blog
U
Unit 42
P
Proofpoint News Feed
V
V2EX

博客园 - Shapley

项目心得 进程间通讯方式 C#使用MCP协议调用大模型示例 SQL Server LEAD函数实践 sql server行专列一例 数据库字段排序方法两则 Sql Server生成ULID例子 审批流进化记 winform+Task+async 献丑贴:Task.Run中foreach优化 Sql Server Begin TRY sample No service for type 'Microsoft.AspNetCore.Mvc.ViewFeatures.Filters.ValidateAntiforgeryTokenAuthorizationFilter' has been registered. 某低代码平台自定义控件技术点 Element-plus的el-date-picker控件动态切换中英文方案 Chrome浏览器无法查看页面跳转前的请求日志及解决办法 element-plus上传视频并生成缩略图(封面)方案 JWT自动刷新草案 Ajax方法POST的两种提交方式 H5项目在微信浏览器运行实录 Sql Server变量声明及使用技巧 修改Dify的Nginx对外访问端口 Task with Console(with SemaphoreSlim) Task实战 asp.net core 9.0发布centos7.9 Barrier
CountdownEvent
Shapley · 2024-10-20 · via 博客园 - Shapley

CountdownEvent是一种同步结构,主要用来协调多种同步处理后的结果场景使用。其含义为:定义一个多信号的结构,然后在应用时判断信号是否全部到达,如果全部到达则继续往下运行,否则进行阻塞,有意思的是,如果阻塞已过,那么再次运行到wait()时,线程是不会再次阻塞的,除非调用reset()重新初始化后才可以。这点和其余的同步结构不一样。

示例如下:

internal class Program
{
    static CountdownEvent e = new CountdownEvent(3);
    static bool isOutput = true;

    static int i = 0;
    static void Main(string[] args)
    {
        Thread t = new Thread(ProcessData);
        t.Start();

        Console.WriteLine("启动");
        i++;

        Console.WriteLine("信号1已到");
        e.Signal();
        Console.WriteLine("信号2已到");
        e.Signal();
        Console.WriteLine("信号3已到");
        e.Signal();

        Console.ReadLine();
        i++;
        Console.WriteLine("信号1又到");
        e.Signal();
        Console.WriteLine("信号2又到");
        e.Signal();
        Console.WriteLine("信号3又到");
        e.Signal();

        Console.ReadKey();

    }
    static void ProcessData()
    {
        while (isOutput)
        {
            Console.WriteLine("阻塞等待信号");
            e.Wait();
            Console.WriteLine("阻塞已过,处理:Processed {0}", i);
            e.Reset();
            if (i > 1)
            {
                isOutput = false;
            }
        }
        if (!isOutput)
        {
            e.Dispose();
            Console.WriteLine("处理完成");
        }
    }

}

运行结果: