通过semaphore控制线程池使用

「爱情、让人受尽委屈。」 2022-08-31 06:54 153阅读 0赞

主线程

public static ExecutorService washPool;
    { 
    //初始化线程池 300个线程
     washPool = Executors.newFixedThreadPool(300);
    }
    
    //设置静态变量 Semaphore 许可证数量为线程池大小
    private static  final Semaphore sp = new Semaphore(300);
    //循环开启300个线程
     for (int i = 0; i<300 ;i++) { 
                MyThread myThread= new MyThread (sp);
                washPool.execute(myThread);
            }

自定义线程

//线程重写run方法 在线程开始时获取许可，线程结束时 释放许可
     @Override
        public void run() { 
            try { 
                sp.acquire();//获取许可
         		do something();
         		.......
            } catch (InterruptedException e) { 
                e.printStackTrace();
            }
              sp.release(); //释放许可
            }

主线程

//主线程中监听sp
     //当Semaphore的可用许可不达到300时，说明仍有线程在工作 ，当前线程休眠10s 
     //sp.availablePermits() 获取可用许可数量
            while (sp.availablePermits() !=300){ 
                try { 
                    Thread.sleep(10000);
                } catch (InterruptedException e) { 
                    e.printStackTrace在这里插入代码片();
                }
            }
            //执行到这，说明线程池的工作线程为零，任务已全部完成
            do something()；

发表评论取消回复

表情：

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

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

相关阅读

相关理解并解决Java中的并发控制线程池

Java中的并发控制，特别是对于大量的、耗时的任务，通常会使用线程池。线程池是一种资源管理器，它维护一组可重用的线程，当有新的任务到来时，可以将任务提交给线程池，由线程池自动分

野性酷女/ 2024年11月22日 09:30/ 0 赞/ 5 阅读

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

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

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

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

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

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

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

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

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

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

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

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

相关 java控制线程（一）

java控制线程(一) 控制线程-join方法 -------------------- java的线程支持提供了一些便捷的工具方法： join线程：Threa

待我称王封你为后i/ 2022年03月28日 15:12/ 0 赞/ 265 阅读

相关 java控制线程（三）

java控制线程(三) sleep和yield -------------------- 线程睡眠：sleep > 如果需要让当前正在执行的线程暂停一段时间，并

男娘i/ 2022年03月27日 12:54/ 0 赞/ 271 阅读

相关 java控制线程（二）

java控制线程(二) 控制线程-守护线程 -------------------- 后台线程： what：有一种线程，它是在后台运行的，它的任务是为其他的

冷不防/ 2022年03月27日 05:52/ 0 赞/ 217 阅读

相关 Java使用阻塞队列控制线程通信

一点睛阻塞队列主要用在生产者/消费者的场景，下面这幅图展示了一个线程生产、一个线程消费的场景： ![20190601145930983.png][] 负责生产的线程不

ゝ一世哀愁。/ 2021年09月19日 17:50/ 0 赞/ 378 阅读

相关 Java使用Condition控制线程通信

一点睛当使用Lock对象来保证同步时，Java提供了一个Condition类来保持协调，使用Condition可以让那些已经得到Lock对象、却无法继续执行的线程释放Lo

约定不等于承诺〃/ 2021年09月19日 16:46/ 0 赞/ 321 阅读