12.线程间协作：栅栏CyclicBarrier

2023-12-20 20:58
文章标签 线程 协作 栅栏 cyclicbarrier

本文主要是介绍12.线程间协作：栅栏CyclicBarrier，希望对大家解决编程问题提供一定的参考价值，需要的开发者们随着小编来一起学习吧！

目录

  • 1.使用
  • 2.CyclicBarrier的典型应用场景

1.使用

有时候多个线程可能需要相互等待对方执行到代码中的某个地方（集合点），这时这些线程才能够继续执行 。JDK 1.5 开始引入了一个类java.util.concurrent.CyclicBarrier, 该类可以用来实现这种等待。使用CyclicBarrier实现等待的线程被称为参与方 (Party)。参与方只需要执行CyclicBarrier.await() 就可以实现等待。尽管从应用代码的角度来看，参与方是并发执行CyclicBarrier.await() 的。但是， CyclicBarrier 内部维护了一个显式锁，这使得其总是可以在所有参与方中区分出一个最后执行CyclicBarrier.await()的线程，该线程被称为最后一个线程。除最后一个线程外的任何参与方执行 CyclicBarrier.await()都会导致该线程被暂停（线程生命周期状态变为 WAITING)。 最后一个线程执行 CyclicBarrier.await()会使得使用相应 CyclicBarrie 实例的其他所有参与方被唤醒，而最后一个线程自身并不会被暂停。与CountDownLatch不同的是，CyclicBarrier 实例是可重复使用的：所有参与方被唤醒的时候，任何线程再次执行 CyclicBarrier.await()又会被暂停，直到这些线程中的最后一个线程执行了CyclicBarrier.await() 。
CyclicBarrier的其中一个构造器允许我们指定一个被称为barrierAction 的任务 (Runnable 接口实例）。barrierAction会被最后一个线程执行CyclicBarrier. await方法时执行，该任务执行结束后其他等待线程才会被唤醒。

2.CyclicBarrier的典型应用场景

  • 使迭代 (Iterative) 算法并发化。在并发化的迭代算法中，迭代操作是由多个工作者线程并行执行的。CyclicBarrier可用来实现执行迭代操作的任何一个工作者线程必须等待其他工作者线程也完成当前迭代操作的情况下才继续其下一轮的迭代操作，以便形成迭代操作的中间结果作为下一轮迭代的基础（输入）。因此，该应用场景从代码上反映出来的是， CyclicBarrier.await()调用是在一个循环中执行的。
  • 在测试代码中模拟高并发。在编写多线程程序的测试代码时，我们常常需要使用有限的工作者线程来模拟高并发操作。为此，CyclicBarrier可用来实现这些工作者线程中的任意一个线程在执行其操作前必须等待其他线程也准备就绪，即使得这些工作者线程尽可能地在同一时刻开始其操作。

这篇关于12.线程间协作：栅栏CyclicBarrier的文章就介绍到这儿，希望我们推荐的文章对编程师们有所帮助！


http://www.chinasem.cn/article/517472。

相关文章

线程的四种操作

线程的四种操作

所属专栏：Java学习        1. 线程的开启 start和run的区别： run：描述了线程要执行的任务，也可以称为线程的入口 start：调用系统函数，真正的在系统内核中创建线程（创建PCB，加入到链表中），此处的start会根据不同的系统，分别调用不同的api，创建好之后的线程，再单独去执行run（所以说，start的本质是调用系统api，系统的api
阅读更多...
java线程深度解析（六）——线程池技术

java线程深度解析（六）——线程池技术

http://blog.csdn.net/Daybreak1209/article/details/51382604 一种最为简单的线程创建和回收的方法： [html]  view plain copy new Thread(new Runnable(){                @Override               public voi
阅读更多...
java线程深度解析（五）——并发模型（生产者-消费者）

java线程深度解析（五）——并发模型（生产者-消费者）

http://blog.csdn.net/Daybreak1209/article/details/51378055 三、生产者-消费者模式     在经典的多线程模式中，生产者-消费者为多线程间协作提供了良好的解决方案。基本原理是两类线程，即若干个生产者和若干个消费者，生产者负责提交用户请求任务（到内存缓冲区），消费者线程负责处理任务（从内存缓冲区中取任务进行处理），两类线程之
阅读更多...
java线程深度解析（四）——并发模型（Master-Worker）

java线程深度解析（四）——并发模型（Master-Worker）

http://blog.csdn.net/daybreak1209/article/details/51372929 二、Master-worker ——分而治之      Master-worker常用的并行模式之一，核心思想是由两个进程协作工作，master负责接收和分配任务，worker负责处理任务，并把处理结果返回给Master进程，由Master进行汇总，返回给客
阅读更多...
java线程深度解析（二）——线程互斥技术与线程间通信

java线程深度解析（二）——线程互斥技术与线程间通信

http://blog.csdn.net/daybreak1209/article/details/51307679      在java多线程——线程同步问题中，对于多线程下程序启动时出现的线程安全问题的背景和初步解决方案已经有了详细的介绍。本文将再度深入解析对线程代码块和方法的同步控制和多线程间通信的实例。 一、再现多线程下安全问题 先看开启两条线程，分别按序打印字符串的
阅读更多...
java线程深度解析（一）——java new 接口？匿名内部类给你答案

java线程深度解析（一）——java new 接口？匿名内部类给你答案

http://blog.csdn.net/daybreak1209/article/details/51305477 一、内部类 1、内部类初识 一般，一个类里主要包含类的方法和属性，但在Java中还提出在类中继续定义类（内部类）的概念。 内部类的定义：类的内部定义类 先来看一个实例 [html]  view plain copy pu
阅读更多...
C#线程系列(1)：BeginInvoke和EndInvoke方法

C#线程系列(1)：BeginInvoke和EndInvoke方法

一、线程概述 在操作系统中一个进程至少要包含一个线程，然后，在某些时候需要在同一个进程中同时执行多项任务，或是为了提供程序的性能，将要执行的任务分解成多个子任务执行。这就需要在同一个进程中开启多个线程。我们使用 C# 编写一个应用程序（控制台或桌面程序都可以），然后运行这个程序，并打开 windows 任务管理器，这时我们就会看到这个应用程序中所含有的线程数，如下图所示。
阅读更多...
71-java 导致线程上下文切换的原因

71-java 导致线程上下文切换的原因

Java中导致线程上下文切换的原因通常包括： 线程时间片用完：当前线程的时间片用完，操作系统将其暂停，并切换到另一个线程。 线程被优先级更高的线程抢占：操作系统根据线程优先级决定运行哪个线程。 线程进入等待状态：如线程执行了sleep()，wait()，join()等操作，使线程进入等待状态或阻塞状态，释放CPU。 线程占用CPU时间过长：如果线程执行了大量的I/O操作，而不是CPU计算
阅读更多...
使用条件变量实现线程同步：C++实战指南

使用条件变量实现线程同步：C++实战指南

使用条件变量实现线程同步：C++实战指南 在多线程编程中，线程同步是确保程序正确性和稳定性的关键。条件变量（condition variable）是一种强大的同步原语，用于在线程之间进行协调，避免数据竞争和死锁。本文将详细介绍如何在C++中使用条件变量实现线程同步，并提供完整的代码示例和详细的解释。 什么是条件变量？ 条件变量是一种同步机制，允许线程在某个条件满足之前进入等待状态，并在条件满
阅读更多...
pythons强行杀掉线程的方法

pythons强行杀掉线程的方法

使用ctypes强行杀掉线程 import threading import time import inspect import ctypes def _async_raise(tid, exctype): """raises the exception, performs cleanup if needed""" tid = ctypes.c_long(tid) if n
阅读更多...

Copyright China编程 23002807@qq.com

沪ICP备2023033072号-2