用于线程池,连接池,
处理完之后,才允许下一个操作的。
package demo.thread;
import java.util.concurrent.CountDownLatch;
import java.util.concurrent.Semaphore;
public class ThreadMain {
public static void main(String[] args) throws Exception {
final Semaphore sema = new Semaphore(3);
for (int i = 0; i < 10; i++) {
final int no = i;
Runnable thread = new Runnable() {
public void run() {
try {
System.out.println("用户 " + no + "连接上了: ");
Thread.sleep(300L);
sema.acquire();
System.out.println("用户 " + no + "开始访问后台程序...");
Thread.sleep(1000L);
sema.release();
System.out.println("用户 " + no + "访问结束.");
} catch (InterruptedException e) {
e.printStackTrace();
}
}
};
new Thread(thread).start();
}
System.out.println("Main thread end...");
}
}
用户 2连接上了:
用户 5连接上了:
用户 3连接上了:
用户 1连接上了:
用户 6连接上了:
用户 7连接上了:
Main thread end...
用户 0连接上了:
用户 9连接上了:
用户 4连接上了:
用户 8连接上了:
用户 5开始访问后台程序...
用户 6开始访问后台程序...
用户 2开始访问后台程序...
用户 2访问结束.
用户 7开始访问后台程序...
用户 5访问结束.
用户 6访问结束.
用户 3开始访问后台程序...
用户 1开始访问后台程序...
用户 4开始访问后台程序...
用户 3访问结束.
用户 0开始访问后台程序...
用户 7访问结束.
用户 1访问结束.
用户 8开始访问后台程序...
用户 4访问结束.
用户 0访问结束.
用户 9开始访问后台程序...
用户 8访问结束.
用户 9访问结束.