java多线程学习-java.util.concurrent详解(三) Semaphore

转载于：http://janeky.iteye.com/blog/769965

我们先来学习一下JDK1.5 API中关于这个类的详细介绍： 
“一个计数信号量。从概念上讲，信号量维护了一个许可集。如有必要，在许可可用前会阻塞每一个 acquire()，然后再获取该许可。每个 release() 添加一个许可，从而可能释放一个正在阻塞的获取者。但是，不使用实际的许可对象，Semaphore 只对可用许可的号码进行计数，并采取相应的行动。”

我们一般用它来控制某个对象的线程访问对象

例如，对于某个容器，我们规定，最多只能容纳n个线程同时操作 
使用信号量来模拟实现

package com.winterbe.java8.samples.concurrent;

import java.util.Collections;
import java.util.HashSet;
import java.util.Random;
import java.util.Set;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.Semaphore;
/*
 * Semaphore通常用于对象池的控制
 * */
public class TestSemaphore {

	public static void main(String[] args) throws InterruptedException {
		ExecutorService exec = Executors.newCachedThreadPool();
		TestSemaphore t = new TestSemaphore();
		final BoundedHashSet<String> set = t.getSet();
        final int MAX=10;
		for (int i = 0; i < MAX; i++) {// 十个线程同时操作add
			exec.execute(new Runnable() {
				public void run() {
					try {
						set.deal(Thread.currentThread().getName());
					} catch (InterruptedException e) {
						e.printStackTrace();
					}
				}
			});
		}
		exec.shutdown();
	}

	public BoundedHashSet<String> getSet() {
		return new BoundedHashSet<String>(2);// 定义一个边界约束为2的线程
	}

	class BoundedHashSet<T> {
		private final Set<T> set;
		private final Semaphore semaphore;
		final Random random = new Random();

		public BoundedHashSet(int bound) {
			this.set = Collections.synchronizedSet(new HashSet<T>());
			this.semaphore = new Semaphore(bound, true);
		}

		public void deal(T o) throws InterruptedException {
		    System.out.println("availablePermits:"+semaphore.availablePermits());
			semaphore.acquire();// 信号量控制可访问的线程数目,如果访问的数量达到Bount,则阻塞
			set.add(o);
			System.out.printf("add:%s%n", o);
			Thread.sleep(random.nextInt(1000));//Sleep 一定时间后，师傅信号量，这里也就是业务逻辑处理的时间
			semaphore.release();// 释放掉信号量
			System.out.printf("remove:%s%n", o);

		}

	}
}

　　   总结：Semaphore通常用于对象池的控制