Java 线程技术之同步计数器Semaphore

用于线程池,连接池,

处理完之后,才允许下一个操作的。


Java 线程技术之同步计数器Semaphore

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访问结束.


上一篇:Android获取cpu使用率,剩余内存和硬盘容量


下一篇:函数计算新功能-----支持C#函数