多线程同步问题：Java中的Semaphore和CyclicBarrier示例

原创 ╰+哭是因爲堅強的太久メ 2024-10-10 15:06 52阅读 0赞

在Java中，`Semaphore` 和 `CyclicBarrier` 都是用于线程同步的工具。这里我将分别提供这两个类的基本使用示例。

1. Semaphore（信号量）：

`Semaphore` 是一个可以限制同时访问资源数量的对象。当信号量值为0时，调用 acquire() 方法的线程会被阻塞；相反，当信号量值大于0时，线程可以直接通过 acquire() 方法进入临界区。

示例代码：
```java
import java.util.concurrent.Semaphore;

public class SemaphoreExample {
    private final Semaphore permit = new Semaphore(1);

public void threadAction() {
        try {
            // 获取许可证
            permit.acquire();

// 在这里执行线程任务
            System.out.println("Thread 1 executing...");

// 释放许可证，让其他线程有机会获取
            permit.release();
        } catch (Exception e) {
            e.printStackTrace();
        }
    }

public static void main(String[] args) {
        SemaphoreExample example = new SemaphoreExample();

Thread thread1 = new Thread(() -> example.threadAction()));
        Thread thread2 = new Thread(() -> example.threadAction()));

// 启动线程
        thread1.start();
        thread2.start();
    }
}
```

2. CyclicBarrier（循环屏障）：

`CyclicBarrier` 是一个用于控制一组线程共同到达某个固定点的工具。当所有线程都到达该点时，屏障会自动释放，允许后续线程进入。

示例代码：
```java
import java.util.concurrent.CyclicBarrier;

public class CyclicBarrierExample {
    private final CyclicBarrier barrier = new CyclicBarrier(2);

public void threadAction() throws Exception {
        // 等待所有线程到达屏障点
        barrier.await();

System.out.println("Thread 1 executing...");

// 当某个线程到达屏障点时，释放屏障
        barrier.reset();
    }

public static void main(String[] args) {
        CyclicBarrierExample example = new CyclicBarrierExample();

Thread thread1 = new Thread(() -> example.threadAction()));
        Thread thread2 = new Thread(() -> example.threadAction()));

// 启动线程
        thread1.start();
        thread2.start();
    }
}
```

以上示例分别展示了如何使用`Semaphore` 和 `CyclicBarrier` 进行多线程同步。

文章版权声明：注明蒲公英云原创文章，转载或复制请以超链接形式并注明出处。

发表评论取消回复

表情：

评论列表（有 0 条评论，52人围观）

还没有评论，来说两句吧...

相关阅读

相关 Java多线程同步问题：Semaphore、CyclicBarrier和JoinPoint示例

Java中的多线程同步主要通过四种机制实现，包括Semaphore（信号量）、CyclicBarrier（循环屏障）和JoinPoint（连接点）。这里将简单介绍它们的使用方法

雨点打透心脏的1/2处/ 2024年11月25日 21:33/ 0 赞/ 41 阅读

相关多线程同步：Java中的Semaphore使用示例

在Java中，`Semaphore`是线程同步的一种工具，它允许固定数量的并发线程访问共享资源。以下是一个简单的`Semaphore`使用示例： ```java impo

﹏ヽ暗。殇╰゛Y/ 2024年11月21日 04:51/ 0 赞/ 8 阅读

相关多线程同步问题：Lock和Semaphore的区别示例

`Lock` 和 `Semaphore` 是 Java 中两种常用的多线程同步工具，各有特点。下面以一个简单的生产者消费者场景来对比理解。 1. **Lock**： -

秒速五厘米/ 2024年10月17日 07:51/ 0 赞/ 54 阅读

相关 Java多线程同步：Semaphore和CyclicBarrier的区别

在Java多线程编程中，Semaphore（信号量）和CyclicBarrier（循环屏障）都是用于线程间的互斥与协调的工具。它们的区别主要体现在以下几个方面： 1. **作

小鱼儿/ 2024年10月14日 07:57/ 0 赞/ 54 阅读

相关多线程同步问题：Java中的Semaphore和CyclicBarrier示例

在Java中，`Semaphore` 和 `CyclicBarrier` 都是用于线程同步的工具。这里我将分别提供这两个类的基本使用示例。 1. Semaphore（信号量）

╰+哭是因爲堅強的太久メ/ 2024年10月10日 15:06/ 0 赞/ 53 阅读

相关多线程同步问题：Java中CountDownLatch、Semaphore用法示例

`CountDownLatch`和`Semaphore`是Java中两种常用的线程同步工具，主要用于控制多个线程的执行顺序。 1. `CountDownLatch`示例： `

心已赠人/ 2024年09月23日 07:42/ 0 赞/ 92 阅读

相关多线程下同步问题：CountDownLatch、CyclicBarrier和Semaphore的区别示例

CountDownLatch、CyclicBarrier和Semaphore都是Java中用于线程同步的工具。它们的主要区别在于控制不同类型的活动。 1. CountDown

r囧r小猫/ 2024年09月21日 02:27/ 0 赞/ 80 阅读

相关 Java多线程同步：CountDownLatch和CyclicBarrier示例

在Java多线程编程中，同步工具如CountDownLatch和CyclicBarrier是非常有用的。下面分别给出这两个类的使用示例。 1. CountDownLatch

客官°小女子只卖身不卖艺/ 2024年09月14日 16:54/ 0 赞/ 96 阅读

相关 java多线程 CountDownLatch、CyclicBarrier和Semaphore

java多线程 CountDownLatch、CyclicBarrier和Semaphore 1. 概念 CountDownLatch：减数计数器，只有当所有线程到

桃扇骨/ 2022年12月28日 07:48/ 0 赞/ 231 阅读

相关 java多线程同步技术CyclicBarrier、CountDownLatch、Semaphore

一、CyclicBarrier 通过它可以实现让一组线程等待至某个状态之后再全部同时执行。叫做回环是因为当所有等待线程都被释放以后，CyclicBarrie

曾经终败给现在/ 2022年03月20日 10:46/ 0 赞/ 338 阅读