在Java并发编程中,Semaphore (信号量)主要用来控制线程并发的数量。
主要方法:
Semaphore(int permits):构造方法,创建具有给定许可数的计数信号量并设置为非公平信号量。
Semaphore(int permits,boolean fair):构造方法,当fair等于true时,创建具有给定许可数的计数信号量并设置为公平信号量。
void acquire():获取一个许可前线程将一直阻塞。
void acquire(int n):获取给定数目许可,在提供这些许可前一直将线程阻塞。
boolean tryAcquire();尝试获取许可,获取到返回true,否则false。
boolean tryAcquire(long timeout,Timeunit unit);在指定时间内尝试获取许可,获取到返回true,否则false。
void release():释放一个许可,将其返回给信号量。
void release(int n):释放n个许可。
int availablePermits():当前可用的许可数。
@Slf4j
public class SempTest{
private final static int count = 9; //最大并发线程
public static void main(String[] args) {
ExecutorService service = Executors.newCachedThreadPool();
Semaphore semaphore = new Semaphore(3); //设置并发线程为 3
for (int i = 0; i < count; i++) {
final int num = i;
service.execute(() -> {
try {
semaphore.acquire(); //获取许可
test(num);
semaphore.release(); //释放许可
} catch (InterruptedException e) {
log.error("exception",e);
}
});
}
service.shutdown();
}
public static void test(int num) throws InterruptedException {
log.debug("{}", num);
Thread.sleep(1000);
}
}
2018-12-12 23:36:34,484 [DEBUG] pool-1-thread-2 [com.eaphy.Test.mianshi] - 1
2018-12-12 23:36:34,484 [DEBUG] pool-1-thread-3 [com.eaphy.Test.mianshi] - 2
2018-12-12 23:36:34,484 [DEBUG] pool-1-thread-1 [com.eaphy.Test.mianshi] - 0
2018-12-12 23:36:35,485 [DEBUG] pool-1-thread-4 [com.eaphy.Test.mianshi] - 3
2018-12-12 23:36:35,485 [DEBUG] pool-1-thread-5 [com.eaphy.Test.mianshi] - 4
2018-12-12 23:36:35,485 [DEBUG] pool-1-thread-6 [com.eaphy.Test.mianshi] - 5
2018-12-12 23:36:36,486 [DEBUG] pool-1-thread-8 [com.eaphy.Test.mianshi] - 7
2018-12-12 23:36:36,486 [DEBUG] pool-1-thread-9 [com.eaphy.Test.mianshi] - 8
2018-12-12 23:36:36,486 [DEBUG] pool-1-thread-7 [com.eaphy.Test.mianshi] - 6