Java并发编程实战：使用Semaphore控制线程数量

原创墨蓝 2024-09-04 08:51 54阅读 0赞

在Java并发编程中，`Semaphore`是一个信号量对象，它用于限制特定类型的访问。其中一种常见的用途就是控制线程的数量。

下面是一个简单的例子，演示如何使用Semaphore来限制同时执行的任务数量：

```java
import java.util.concurrent.Semaphore;

public class SemaphoreExample {
    private Semaphore semaphore = new Semaphore(2); // 初始化，最多允许两个线程

public void threadTask() throws InterruptedException {
        semaphore.acquire(); // 获取信号量，表示一个线程正在使用资源
        // 这里是你的任务代码
        System.out.println("Thread " + Thread.currentThread().getId() + " is running tasks..."); // 执行任务后输出信息
        semaphore.release(); // 释放信号量，表示一个线程完成了对资源的使用
    }

public static void main(String[] args) {
        SemaphoreExample example = new SemaphoreExample();
        Thread thread1 = new Thread(example::threadTask, "Thread 1"));
        Thread thread2 = new Thread(example::threadTask, "Thread 2"));

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

// 等待所有线程结束，保证程序的完整性
        thread1.join();
        thread2.join();
    }
}
```

在这个例子中，我们创建了一个Semaphore对象，并初始化为允许最多两个线程同时执行。每个需要使用资源的线程在获取信号量后开始工作，任务完成后释放信号量。

注意：`join()`方法用于等待当前线程结束。在这里，它是用来确保所有任务线程完成它们的工作。

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

发表评论取消回复

表情：

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

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

相关阅读

相关 Java多线程并发控制：Semaphore实战案例

在Java中，`Semaphore`是一种用于控制同时访问特定资源的线程数量的同步辅助类。它通过维护一组许可（permits），来控制对某些资源的访问。线程可以通过调用`acq

朴灿烈づ我的快乐病毒、/ 2024年11月13日 23:53/ 0 赞/ 14 阅读

相关 Java并发编程实战：CountDownLatch与Semaphore的应用

在Java并发编程中，CountDownLatch和Semaphore是两种重要的同步工具。它们分别用于不同场景下的线程管理和协调。 1. CountDownLatch： C

亦凉/ 2024年10月20日 10:30/ 0 赞/ 51 阅读

相关 Java并发编程：CountDownLatch和Semaphore实战案例

在Java的并发编程中，`CountDownLatch` 和 `Semaphore` 是两个常用的同步工具。下面我们将通过实例来理解和运用这两种工具。 1. CountDow

超、凢脫俗/ 2024年10月08日 17:21/ 0 赞/ 81 阅读

相关 Java并发编程实战：使用Semaphore控制线程

Semaphore是Java中一种多线程同步工具，它允许最多n个不同的线程访问同一资源。当一个线程进入临界区并获取了Semaphore的计数器值后，其他想要进入临界区的线程必须

水深无声/ 2024年09月23日 07:09/ 0 赞/ 68 阅读

相关 Java并发编程实战：Semaphore使用场景示例

Semaphore（信号量）是Java中并发工具包的一部分，用于控制对共享资源的访问。它主要应用于以下几种场景： 1. **线程互斥**：当多个线程需要同时访问一个资源时，可

r囧r小猫/ 2024年09月17日 00:12/ 0 赞/ 60 阅读

相关 Java并发编程：使用Semaphore解决线程同步问题

在Java中，`Semaphore`是一种信号量对象，用于控制多个线程对共享资源的访问。它的工作原理类似于锁，但提供了更灵活的多线程同步机制。以下是如何使用Semaphor

╰+攻爆jí腚メ/ 2024年09月16日 12:39/ 0 赞/ 48 阅读

相关 Java并发编程实战：使用Semaphore控制线程数量

在Java并发编程中，`Semaphore`是一个信号量对象，它用于限制特定类型的访问。其中一种常见的用途就是控制线程的数量。下面是一个简单的例子，演示如何使用Semaph

墨蓝/ 2024年09月04日 08:51/ 0 赞/ 55 阅读

相关通过semaphore控制线程池使用

主线程 public static ExecutorService washPool; { //初始化线程池 300个线程 washPoo

「爱情、让人受尽委屈。」/ 2022年08月31日 06:54/ 0 赞/ 151 阅读

相关 Java使用ExecutorService控制线程数量

代码如下 package com.spider.run; import com.spider.common.tools.StringHandle;

布满荆棘的人生/ 2022年05月17日 05:36/ 0 赞/ 359 阅读

相关 Java并发编程-Semaphore使用

Java并发编程-Semaphore使用使用场景：Semaphore（信号量）同时运行多少个并发执行，比如我现在设置30个线程访问，可以通过Semaphore控制同时多个

﹏ヽ暗。殇╰゛Y/ 2021年11月16日 05:58/ 0 赞/ 395 阅读