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(); } }

旧城

评论

发表评论取消回复

旧城

评论

发表评论 取消回复

发表评论取消回复