使用信号量semaphore实现一个无界线程池

2019-11-14 20:08:05 阅读：297 来源： 互联网

标签：程池 exec semaphore 信号量线程 Semaphore release public

Semaphore 用法在调用accquire之后到release之间，别的线程会阻塞，当然前提是信用量已经没有可用的了。

 1 package com.citi.test.mutiplethread.demo08;
 2 
 3 import java.util.concurrent.Executor;
 4 import java.util.concurrent.Semaphore;
 5 
 6 public class BoundedExecutor {
 7     private final Executor exec;
 8     private final Semaphore semaphore;
 9     public BoundedExecutor(Executor exec,int bound) {
10         this.exec=exec;
11         this.semaphore=new Semaphore(bound);
12     } 
13     public void submitTask(final Runnable runnable) throws InterruptedException{
14         //获取一个许可 在acquire之后如果信号量已经没有了，那么下个线程再进来会等待，直到有线程调用release方法
15         semaphore.acquire();
16         try {
17             exec.execute(new Runnable() {
18                 @Override
19                 public void run() {
20                     try {
21                         runnable.run();
22                     }finally{
23                         semaphore.release();
24                     }
25                 }
26             });
27         } catch (Exception e) {
28             semaphore.release();
29         }
30     }
31 }

标签：程池,exec,semaphore,信号量,线程,Semaphore,release,public
来源： https://www.cnblogs.com/liumy/p/11861101.html

本站声明： 1. iCode9 技术分享网（下文简称本站）提供的所有内容，仅供技术学习、探讨和分享；
2. 关于本站的所有留言、评论、转载及引用，纯属内容发起人的个人观点，与本站观点和立场无关；
3. 关于本站的所有言论和文字，纯属内容发起人的个人观点，与本站观点和立场无关；
4. 本站文章均是网友提供，不完全保证技术分享内容的完整性、准确性、时效性、风险性和版权归属；如您发现该文章侵犯了您的权益，可联系我们第一时间进行删除；
5. 本站为非盈利性的个人网站，所有内容不会用来进行牟利，也不会利用任何形式的广告来间接获益，纯粹是为了广大技术爱好者提供技术内容和技术思想的分享性交流网站。

ICode9

使用信号量semaphore实现一个无界线程池