Java信号量Semaphore

所在包:java.util.concurrent.Semaphore
semaphore 英[ˈseməfɔ:(r)] 美[ˈsɛməˌfɔr, -ˌfor]
n. 臂板信号系统,(铁道)臂板信号装置; vt.& vi. 发出信号,打旗语;
一个计数信号量。从概念上讲,信号量维护了一个许可集。如有必要,在许可可用前会阻塞每一个acquire(),然后再获取该许可。每个release()添加一个许可,从而可能释放一个正在阻塞的获取者。但是,不使用实际的许可对象,Semaphore只对可用许可的号码进行计数,并采取相应的行动。
Semaphore 通常用于限制可以访问某些资源(物理或逻辑的)的线程数目。
package jiucheng.demo;

import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.Semaphore;

public class Sem {
    private Semaphore semaphore = new Semaphore(5);
    private Object lock = new Object();
    private int wcCount = 5;

    public void wc() {
        try {
            semaphore.acquire();
            System.out.println("b wcCount = " + wcCount);
            use();
            Thread.sleep((long) (Math.random() * 10000));
            unuse();
            System.out.println("a wcCount = " + wcCount);
        } catch (InterruptedException e) {
            e.printStackTrace();
        } finally {
            semaphore.release();
        }
    }

    private void use() {
        synchronized (lock) {
            wcCount += -1;
        }
    }

    private void unuse() {
        synchronized (lock) {
            wcCount += 1;
        }
    }

    public static void main(String[] args) {
        final Sem sem = new Sem();
        ExecutorService es = Executors.newFixedThreadPool(20);
        for (int i = 0; i < 50; i++) { es.execute(new Runnable() { public void run() { sem.wc(); } }); } es.shutdown(); } }
38

评论

  1. 博客做的不错,厉害

    1. @匿名 是同事吧,评论IP是公司的。

发表评论

电子邮件地址不会被公开。 必填项已用*标注

点击更换