Semaphore信号量

public class SemaphoreTest implements Runnable {
    Semaphore samephore;
    int id;

    public SemaphoreTest(Semaphore samephore, int id) {
        this.samephore = samephore;
        this.id = id;
    }

    @Override
    public void run() {

        // TODO Auto-generated method stub
        try {
            samephore.acquire();
            Thread.sleep(1000);
            System.out.println("客户编号" + id + "正在办理任务");
            samephore.release();
        } catch (InterruptedException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }

    }

    public static void main(String[] args) {
        Semaphore samephore = new Semaphore(10,true);// 限制并发访问次数为10 true为采用公平模式。先进的先遍历
        for (int i = 0; i < 20; i++) {
            new Thread(new SemaphoreTest(samephore, i)).start();;
        }
    }

}