码迷,mamicode.com
首页 > 其他好文 > 详细

信号量实现对象池

时间:2019-04-09 15:17:10      阅读:168      评论:0      收藏:0      [点我收藏+]

标签:线程池   turn   func   function   UNC   size   print   限流   信号量   

class ObjPool<T,R>{
  final List<T> pool;
  //信号量实现限流器
  final Semaphore sem;
  //构造方法
  ObjectPool(int size,T t){
    pool = new Vector<T>(){};
    for(int i=0; i<size; i++){
      pool.add(t);
    }
    sem = new Semaphore(size);
  }
  
  R exec(Function<T,R> func){
    T t = null;
    sem.acquire();
    try{
      t = pool.remove(0);
      return func.apply(t);
    }finally{
      pool.add(t);
      sem.release();
    }
  }

  //创建线程池
  ObjPool<Long,String> pool =
    new ObjPool<Long, String>(10,2);
  //通过对象池获取t,之后执行
  pool.exec(t -> {
    System.out.println(t);
    return t.toString();
  })
}





 

信号量实现对象池

标签:线程池   turn   func   function   UNC   size   print   限流   信号量   

原文地址:https://www.cnblogs.com/zhangchiblog/p/10676942.html

(0)
(0)
   
举报
评论 一句话评论(0
登录后才能评论!
© 2014 mamicode.com 版权所有  联系我们:gaon5@hotmail.com
迷上了代码!