用于线程池，连接池，
处理完之后，才允许下一个操作的。
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访问结束.