信号量Semaphore,类似于锁的功能,用于多线程中对一组资源的控制。
acquire方法用于尝试获取一个资源,未获取前将一直等待。release用于释放一个资源,release的前提是已经获得了一个资源。
package multiThread; import java.util.concurrent.Semaphore; public class SemaphoreTest { public static void main(String [ ] args) { int N = 8; //工人数 Semaphore semaphore = new Semaphore(5); //机器数目 for (int i = 1; i < N; i++) new Worker(i, semaphore).start(); } static class Worker extends Thread { private int num; private Semaphore semaphore; public Worker(int num, Semaphore semaphore) { this.num = num; this.semaphore = semaphore; } @Override public void run() { try { semaphore.acquire(); System.out.println("工人" + this.num + "占用一个机器在生产..."); Thread.sleep(2000); System.out.println("工人" + this.num + "释放出机器"); semaphore.release(); } catch (InterruptedException e) { e.printStackTrace(); } } } }
运行的结果为:
工人1占用一个机器在生产...
工人3占用一个机器在生产...
工人2占用一个机器在生产...
工人4占用一个机器在生产...
工人5占用一个机器在生产...
工人3释放出机器
工人2释放出机器
工人6占用一个机器在生产...
工人4释放出机器
工人1释放出机器
工人5释放出机器
工人7占用一个机器在生产...
工人6释放出机器
工人7释放出机器
如果在获取资源的过程中不希望一直等待,也可以使用下面的方法判断是否能获取资源。
tryAcquire(),尝试获取一个许可,若获取成功,则立即返回true,若获取失败,则立即返回false。
tryAcquire(long timeout, TimeUnit unit),尝试获取一个许可,若在指定的时间内获取成功,则立即返回true,否则则立即返回false。
原文:http://www.cnblogs.com/lnlvinso/p/4567720.html