Java多线程Semaphore
Semaphore为并发包中提供用于控制某资源同时可以被几个线程访问的类
实例代码:
// 允许2个线程同时访问
final Semaphore semaphore = new Semaphore(2);
ExecutorService executorService = Executors.newCachedThreadPool();
for (int i = 0; i < 10; i++) {
final int index = i;
executorService.execute(new Runnable() {
public void run() {
try {
semaphore.acquire();
// 这里可能是业务代码
System.out.println("线程:" + Thread.currentThread().getName() + "获得许可:" + index);
TimeUnit.SECONDS.sleep(1);
semaphore.release();
System.out.println("允许TASK个数:" + semaphore.availablePermits());
} catch (InterruptedException e) {
e.printStackTrace();
}
}
});
}
executorService.shutdown();
构造方法1:
public Semaphore(int permits) {
sync = new NonfairSync(permits);
}
permits 初始许可数,也就是最大访问线程数
构造方法2:
public Semaphore(int permits, boolean fair) {
sync = (fair)? new FairSync(permits) : new NonfairSync(permits);
}
permits 初始许可数,也就是最大访问线程数
fair 当设置为false时,线程获取许可的顺序是无序的,也就是说新线程可能会比等待的老线程会先获得许可;当设置为true时,信号量保证它们调用的顺序(即先进先出;FIFO)
主要方法:
void acquire():从信号量获取一个许可,如果无可用许可前 将一直阻塞等待,
void acquire(int permits):获取指定数目的许可,如果无可用许可前 也将会一直阻塞等待
This chapter requires login to view full content. You are viewing a preview.
Login to View Full Content