[闭锁]同步工具类 Semaphore 的使用

小鱼儿 2022-05-16 15:29 170阅读 0赞

通过Semaphore控制流量

import java.util.concurrent.ExecutorService;
    import java.util.concurrent.Executors;
    import java.util.concurrent.Semaphore;
    import java.util.concurrent.TimeUnit;
    
    
    /**
     * 通过Semaphore控制流量
     *
     * @author yuyufeng
     * @date 2018/10/31.
     */
    public class SemaphoreTest {
        //初始化线程池 大小为 10
        private static ExecutorService threadPool = Executors.newFixedThreadPool(10);
        //通过Semaphore控制流量，最多允许5个同时执行
        private static Semaphore semaphore = new Semaphore(5);
    
    
        public static void main(String[] args) {
            for (int i = 0; i < 10; i++) {
                threadPool.execute(new Runnable() {
                    @Override
                    public void run() {
                        try {
                            semaphore.acquire();
                            System.out.println("doSomething...");
                            TimeUnit.SECONDS.sleep(2);
                            semaphore.release();
                        } catch (InterruptedException e) {
                            e.printStackTrace();
                        }
                    }
                });
            }
            threadPool.shutdown();
        }
    }

发表评论取消回复

表情：

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

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

相关阅读

相关 Java中同步工具类如Semaphore的使用示例

Semaphore是Java中的一个同步工具类，主要用于控制对共享资源的并发访问。它类似于信号灯，当信号量值为0时，可以认为信号已被释放，线程可以继续执行；反之，如果信号量大于

朴灿烈づ我的快乐病毒、/ 2024年12月01日 09:12/ 0 赞/ 37 阅读

相关同步工具类：Java中的Semaphore和CountDownLatch实例

在Java中，`Semaphore`和`CountDownLatch`都是线程同步的工具类。 1. Semaphore（信号量）： - 信号量是一种用于控制多个并发访问

清疚/ 2024年10月24日 01:42/ 0 赞/ 36 阅读

相关 Java并发工具类如Semaphore的使用示例

Semaphore是Java并发包中的一种工具类，它类似于信号灯，用于控制同时访问资源的线程数量。以下是一个使用Semaphore的简单示例： ```java impor

亦凉/ 2024年09月24日 12:09/ 0 赞/ 113 阅读

相关 17、详解java线程同步工具Semaphore的使用

Semaphore是java并发包里面的一个工具类，我们限制可以访问某些资源的线程数目就可以使用Semaphore了。这篇文章将对Semaphore的概念和使用进行一个详解。

朱雀/ 2023年06月10日 04:28/ 0 赞/ 24 阅读

相关同步工具类Semaphore

Semaphore提供了资源数量的并发访问控制，也就是线程的并发量代码使用 //一开始有5份共享资源,即5个线程并发量。第二个参数表示是否是公平 Sem

阳光穿透心脏的1/2处/ 2022年09月09日 14:42/ 0 赞/ 202 阅读

相关 [闭锁]同步工具类 CountDownLatch 的使用

CountDownLatch 在使用中，计数器初始化为一个正数，表示需要等待的一组事件的数量。countDown表示有一个事件已经发生了，而await方法等待计数器达到零，表示

Love The Way You Lie/ 2022年06月09日 01:20/ 0 赞/ 185 阅读

相关 JUC学习之同步锁和闭锁

一、同步锁（Lock）：同步锁是一个显示锁，需要通过 lock() 上锁，通过 unlock() 释放锁 public class Test {

分手后的思念是犯贱/ 2022年05月19日 04:41/ 0 赞/ 203 阅读

相关 [闭锁]同步工具类 Semaphore 的使用

通过Semaphore控制流量 import java.util.concurrent.ExecutorService; import java.util.c

小鱼儿/ 2022年05月16日 15:29/ 0 赞/ 171 阅读

相关 JAVA同步工具类——Semaphore信号量

信号量计数信号量(Counting Semaphore)用来控制同时访问某个特定资源的操作数量，或者同时执行某个指定操作的数量； Semaphore管理着一组虚拟许可

谁借莪１个温暖的怀抱￠/ 2022年05月09日 02:58/ 0 赞/ 210 阅读

相关 CountDownLatch同步工具类、递减锁、闭锁

CountDownLatch 同步工具类、递减锁、闭锁名字有多个。可是实际指的都是CountDownLatch，看一不同名字的解释 CountDownLatch 同步

「爱情、让人受尽委屈。」/ 2022年03月11日 06:30/ 0 赞/ 254 阅读