ExecutorService es = Executors.newCachedThreadPool();
// final Semaphore sema=new Semaphore(3); //共有3个通道
final Semaphore sema = new Semaphore(3, true); // 表示按排队的先后顺序进入
for (int i = 0; i < 10; i++) {
es.execute(new Runnable() {
@Override
public void run() {
try {
sema.acquire();
} catch (InterruptedException e) {
e.printStackTrace();
}
System.out.println("线程" + Thread.currentThread().getName()
+ "已进入，当前有" + (3 - sema.availablePermits())
+ "个线程并发");
try {
Thread.sleep(new Random().nextInt(5000));
} catch (InterruptedException e) {
e.printStackTrace();
}
System.out.println("线程" + Thread.currentThread().getName()
+ "即将离开");
sema.release(); // 一个线程释放就会允许另外的线程进入
}
});
es.shutdown();
}
}
运行结果：
线程pool-1-thread-2已进入，当前有2个线程并发
线程pool-1-thread-1已进入，当前有2个线程并发
线程pool-1-thread-3已进入，当前有3个线程并发
线程pool-1-thread-1即将离开
线程pool-1-thread-4已进入，当前有3个线程并发
线程pool-1-thread-4即将离开
线程pool-1-thread-5已进入，当前有3个线程并发
线程pool-1-thread-2即将离开
线程pool-1-thread-9已进入，当前有3个线程并发
线程pool-1-thread-5即将离开
线程pool-1-thread-7已进入，当前有3个线程并发
线程pool-1-thread-3即将离开
线程pool-1-thread-6已进入，当前有3个线程并发
线程pool-1-thread-6即将离开
线程pool-1-thread-8已进入，当前有3个线程并发
线程pool-1-thread-9即将离开
线程pool-1-thread-10已进入，当前有3个线程并发
线程pool-1-thread-7即将离开
线程pool-1-thread-8即将离开
线程pool-1-thread-10即将离开
摘自 jlins_you