Java使用semaphore控制并发线程数

ㅤㅤㅤ ㅤㅤㅤ ㅤㅤㅤㅤㅤㅤㅤㅤㅤㅤㅤㅤㅤㅤㅤ（一个人的理想越崇高，生活越纯洁。——伏尼契） ㅤㅤㅤ ㅤㅤㅤ ㅤㅤㅤㅤㅤㅤㅤㅤㅤ

控制线程池并发线程数

acquire() 获取一个令牌，在获取到令牌、或者被其他线程调用中断之前线程一直处于阻塞状态。 acquire(int permits) 获取一个令牌，在获取到令牌、或者被其他线程调用中断、或超时之前线程一直处于阻塞状态。

acquireUninterruptibly() 获取一个令牌，在获取到令牌之前线程一直处于阻塞状态（忽略中断）。

tryAcquire() 尝试获得令牌，返回获取令牌成功或失败，不阻塞线程。 tryAcquire(long timeout, TimeUnit unit) 尝试获得令牌，在超时时间内循环尝试获取，直到尝试获取成功或超时返回，不阻塞线程。 release() 释放一个令牌，唤醒一个获取令牌不成功的阻塞线程。 hasQueuedThreads() 等待队列里是否还存在等待线程。 getQueueLength() 获取等待队列里阻塞的线程数。 drainPermits() 清空令牌把可用令牌数置为0，返回清空令牌的数量。 availablePermits() 返回可用的令牌数量。

初始化信号量资源

控制并发数为3，第二个参数为true表现遵循先进先出的原则

public Semaphore semaphore = new Semaphore(3, true);

定义线程池

public static final ExecutorService futurePool = Executors.newFixedThreadPool(100,
            new ThreadFactoryBuilder().setNameFormat("future-pool-").build());

使用semaphore限制线程并发数

public M7Response<Object> semaphore() {
          
   
        m7ForExecute();
        for (int i = 0; i < 10; i++) {
          
   
            try {
          
   
                futurePool.execute(() -> asyncSerialTask(semaphore));
            } catch (Exception e) {
          
   
                log.error("semaphore");
            }
        }
        return M7Response.success();
}
public void asyncSerialTask(Semaphore semaphoreParam) {
          
   
    try {
          
   
        semaphoreParam.acquire();
        Thread.sleep(10000);
        System.out.println("asyncSerialTask" + Thread.currentThread().getName() + Thread.currentThread().getId());
    } catch (Exception e) {
          
   
        log.error("asyncSerialTask");
    } finally {
          
   
        semaphoreParam.release();
    }
    System.out.println("异步处理完毕");
}