C# 使用屏障来使多线程并发操作保持同步

写在前面

以下是微软官方对屏障类的介绍,System.Threading.Barrier 可用来作为实现并发同步操作的基本单元,让多个线程(参与者)分阶段并行处理目标算法。在达到代码中的屏障点之前,每个参与者将继续执行,屏障表示工作阶段的末尾;单个参与者到达屏障后将被阻止,直至所有参与者都已达到同一障碍。 所有参与者都已达到屏障后,你可以选择调用阶段后操作。 此阶段后操作可由单线程用于执行操作,而所有其他线程仍被阻止。执行此操作后,所有参与者将不受阻止,继续执行直到满足退出条件。

下面的程序用于统计两个线程使用随机算法重新随机选择字词,分别在同一阶段查找一半解决方案时所需的迭代次数(或阶段数)。在每个线程随机选择字词后,屏障后阶段操作会比较两个结果,以确定整个句子是否按正确的字词顺序呈现。

关键代码如下:

barrier.SignalAndWait()

 设置了代码屏障点,代码运行到这里会等待所有参与的线程都执行完之前的代码。

代码实现

//#define TRACE
using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading;
using System.Threading.Tasks;namespace BarrierSimple
{class Program{static string[] words1 = new string[] { "brown", "jumps", "the", "fox", "quick" };static string[] words2 = new string[] { "dog", "lazy", "the", "over" };static string solution = "the quick brown fox jumps over the lazy dog.";static bool success = false;static Barrier barrier = new Barrier(2, (b) =>{StringBuilder sb = new StringBuilder();for (int i = 0; i < words1.Length; i++){sb.Append(words1[i]);sb.Append(" ");}for (int i = 0; i < words2.Length; i++){sb.Append(words2[i]);if (i < words2.Length - 1)sb.Append(" ");}sb.Append(".");
#if TRACESystem.Diagnostics.Trace.WriteLine(sb.ToString());
#endifConsole.CursorLeft = 0;Console.Write("Current phase: {0}", barrier.CurrentPhaseNumber);if (String.CompareOrdinal(solution, sb.ToString()) == 0){success = true;Console.WriteLine("\r\nThe solution was found in {0} attempts", barrier.CurrentPhaseNumber);}});static void Main(string[] args){Thread t1 = new Thread(() => Solve(words1));Thread t2 = new Thread(() => Solve(words2));t1.Start();t2.Start();// Keep the console window open.Console.ReadLine();}// Use Knuth-Fisher-Yates shuffle to randomly reorder each array.// For simplicity, we require that both wordArrays be solved in the same phase.// Success of right or left side only is not stored and does not count.static void Solve(string[] wordArray){while (success == false){Random random = new Random();for (int i = wordArray.Length - 1; i > 0; i--){int swapIndex = random.Next(i + 1);string temp = wordArray[i];wordArray[i] = wordArray[swapIndex];wordArray[swapIndex] = temp;}// We need to stop here to examine results// of all thread activity. This is done in the post-phase// delegate that is defined in the Barrier constructor.barrier.SignalAndWait();}}}
}

调用示例

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.mzph.cn/news/643941.shtml

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

微信小程序调取相机实现拍照/录屏

1.效果 2.创建子组件 index.wxml代码 <xr-scene id"xr-scenecameraglb" ar-system bind:ready"handleReady" bind:ar-ready"handleARReady" > <!-- 初始化模型 --><xr-assets bind:loaded"handleAssetsLoaded">…

致远OA如何开发 第二篇

第二篇 开发环境以及工具 此栏目技术支持 技术大佬对栏目文章的支持 特别感谢 开发环境 win系统&#xff0c;linux系统&#xff0c;因为在安装的时候会判断是否符合标准服务系统&#xff0c;所以我们可以在安装的bat文件&#xff0c;或者shell文件中删除系统检测的代码&…

【Android】使用build.gradle.kt配置目标架构(abiFIlters)时报错 Val cannot be reassigned

一、 Groovy 配置abi 传统上我们会使用groovy语言的配置文件build.gradle来配置&#xff1a; 在app级别的build.gradle中的 android > defaultConfig 添加子项 ndk {abiFilters armeabi, armeabi-v7a, arm64-v8a, x86, x86_64 }二、出现错误的代码 新版本的默认使用kotli…

WhatsApp怎么营销引流?

随着移动互联网的普及&#xff0c;越来越多的企业开始利用社交媒体平台来进行推广和营销。其中&#xff0c;全球最流行的即时通讯软件之一 WhatsApp&#xff0c;为企业提供了一个新的营销渠道。但是&#xff0c;许多企业不知道如何利用 WhatsApp 进行营销引流。今天&#xff0c…

虚拟机网络配置及Moba工具的使用

A、设置IP和网关 1、设置IP [roothadoop00 ~]# vi /etc/sysconfig/network-scripts/ifcfg-eth0 &#xff08;修改如下标红内容&#xff0c;没有的就添加&#xff09; DEVICEeth0 HWADDR08:00:27:BD:9D:B5 #不用改 TYPEEthernet UUID53e4e4b6-9724-43ab-9da7-68792e611031…

淘宝镜像请求失败解决方法:request to https://registry.npm.taobao.org/vue-loader failed

npm install报错&#xff1a;request to https://registry.npm.taobao.org/vue-loader failed, reason: getaddrinfo ENOTFOUND registry.npm.taobao.org 解决&#xff1a;https://jingyan.baidu.com/article/acf728fd99b16ff8e510a301.html 查看镜像源&#xff1a;npm get re…

不停机迁移,TDengine 在 3D 打印技术中的“焕新”之路

小T导读&#xff1a;自 2021 年我们正式使用 TDengine 至今已接近三年&#xff0c;现在 TDengine 已经成熟应用于我们多个项目当中&#xff0c;凭借着强大的读写存储能力&#xff0c;为我司多项业务的核心数据保驾护航。近期我们团队刚好完成 TDengine 2.x 到 3.x 的数据迁移&a…

VAD语音分割算法详解

1 VAD算法介绍 1.1 语音基本概念 声波通过空气传播&#xff0c;被麦克风接收&#xff0c;通过采样、量化、编码转换为离散的数字信号&#xff0c;即波形文件。音量、音高和音色是声音的基本属性。 采样&#xff1a;原始的语音信号是连续的模拟信号&#xff0c;需要对语音进行…

2024区块链应用趋势,RWA实物资产化

作者 张群&#xff08;赛联区块链教育首席讲师&#xff0c;工信部赛迪特聘资深专家&#xff0c;CSDN认证业界专家&#xff0c;微软认证专家&#xff0c;多家企业区块链产品顾问&#xff09;关注张群&#xff0c;为您提供一站式区块链技术和方案咨询。 实物资产通证化&#xff0…

ffmpeg本地TS和M3U8播放流程及调试过程

本地TS播放过程 本地M3U8播放过程 http工作流程 http分两个步骤 1、获取m3u8文件&#xff0c;这个是在哪里开始读的&#xff1f; 2、获取data数据&#xff0c;这个是从http_read开始读&#xff0c;可以通过修改这里实现buffer数据和引擎对接 3、s->user_agent,s->off,…

Python tkinter (2) —— Button标签

Python的标准Tk GUI工具包的接口 目录 Button 简单示例 设置按钮宽高 设置响应事件 匿名函数调用事件 退出按钮 总结 tkinter系列文章 python tkinter窗口简单实现 Python tkinter (1) —— Label标签 Button Button标签在窗口中显示按钮的控件。 简单示例 实现一个…

1.3编程基础之算术表达式与顺序执行

目录 前言1. AB问题2. 计算(ab)*c的值3. 计算(ab)/c的值4. 带余除法5. 计算分数的浮点数值6. 甲流疫情死亡率7. 计算多项式的值8. 温度表达转化9. 与圆相关的计算10. 计算并联电阻的阻值11. 计算浮点数相除的余数12. 计算球的体积13. 反向输出一个三位数14. 大象喝水15. 苹果和…

STM32 单片机重启(查看上次重启原因)

STM32 HAL 复位源识别 STM32启动后可以识别本次启动是对应哪一种复位源&#xff0c;从而可以根据复位源的状态&#xff0c;做一些特殊处理。 HAL库的复位源识别 以下代码&#xff0c;识别是那种方式进行复位的&#xff0c;只需要将自己在那种方式复位运行的程序添加进去即刻&a…

回归预测 | Matlab基于OOA-SVR鱼鹰算法优化支持向量机的数据多输入单输出回归预测

回归预测 | Matlab基于OOA-SVR鱼鹰算法优化支持向量机的数据多输入单输出回归预测 目录 回归预测 | Matlab基于OOA-SVR鱼鹰算法优化支持向量机的数据多输入单输出回归预测预测效果基本描述程序设计参考资料 预测效果 基本描述 1.Matlab基于OOA-SVR鱼鹰算法优化支持向量机的数据…

go语言(十六)----tag

package mainimport ("fmt""reflect" )type resume struct {Name string info:"name" doc:"我的名字"Sex string info:"sex" }func findTag(str interface{}) {t : reflect.TypeOf(str).Elem()for i : 0;i < t.NumField…

Java面试题136-150

36、用JDBC如何调用存储过程 代码如下&#xff1a; package com.huawei.interview.lym; import java.sql.CallableStatement; import java.sql.Connection; import java.sql.DriverManager; import java.sql.SQLException; import java.sql.Types; public class JdbcTest…

前端面试题-js数据类型-怎么判断是对象还是数组-字符串常用方法-数组常用方法

前端面试题-js部分-js数据类型-怎么判断是对象还是数组-字符串常用方法-数组常用方法 JS数据类型有哪些值类型和引用类型的区别数组的常用方法哪些方法会改变原数组 字符串常用方法对象常用方法怎么判断是对象还是数组 JS数据类型有哪些 数据类型类型描述Number基本类型&#…

Day24_77 组合

77 组合 组合无序&#xff0c;排列有序。1~n个数中选k个数组合&#xff0c;k不确定&#xff0c;组合的方式。 &#xff08;图片来自代码随想录&#xff09;确定回溯法的三部曲&#xff1a; 递归函数的返回值和参数&#xff1a;集合n中取k个数&#xff0c;&#xff0c;每次从…

实用VBA:17.大量word文件中的文本内容进行批量替换

1.需求场景 在工作中可能会遇到需要对大量word文件中的文字内容进行批量替换的情况。相比excel的批量处理&#xff0c;个人感觉word文档中由于包含大量样式信息&#xff0c;批处理时总感觉有顾虑。一者担心影响了文档的格式&#xff0c;误修改了文档的样式&#xff0c;那后果……

【操作系统】实验五 添加内核模块

&#x1f57a;作者&#xff1a; 主页 我的专栏C语言从0到1探秘C数据结构从0到1探秘Linux &#x1f618;欢迎关注&#xff1a;&#x1f44d;点赞&#x1f64c;收藏✍️留言 &#x1f3c7;码字不易&#xff0c;你的&#x1f44d;点赞&#x1f64c;收藏❤️关注对我真的很重要&…