Semaphore--控制并发线程数

2021-03-04 10:30

阅读：458

标签：move 数字 thread try obj import and 数据库连接 ret

Semaphore 美[?sem?f??r]

信号量Semaphore 可以用于做流量控制，特别是公用资源有限的应用场景，比如数据库连接。Semaphore的构造方法

Semaphore（int permits）接受一个整型的数字，表示可用的许可证数量。Semaphore（10）表示允许10个线程获取许可证，也就是最大并发数是10。

Semaphore的用法也很简单，首先使用Semaphore的acquire()方法获取一个许可证，使用完之后调用release()方法归还许可证。调用acquire()如果没有获取到许可证会持续等待直到获取到许可证。

还可以用tryAcquire()方法尝试获取许可证,返回的是一个boolean，可以根据boolean来执行获取许可证失败后的处理逻辑。

Semaphore的其他方法:

int availablePermits()：返回此信号量中当前可用的许可证数。
int getQueueLength()：返回正在等待获取许可证的线程数。
boolean hasQueuedThreads()：是否有线程正在等待获取许可证。
void reducePermits（int reduction）：减少reduction个许可证，是个protected方法。
Collection getQueuedThreads()：返回所有等待获取许可证的线程集合，是个protected方法。

使用Semaphore控制容器边界样例

import java.util.*;
import java.util.concurrent.*;

/**
 * BoundedHashSet
 * 
 * Using Semaphore to bound a collection
 *
 * @author Brian Goetz and Tim Peierls
 */
public class BoundedHashSet  {
    private final Set set;
    private final Semaphore sem;

    public BoundedHashSet(int bound) {
        this.set = Collections.synchronizedSet(new HashSet());
        sem = new Semaphore(bound);
    }

    public boolean add(T o) throws InterruptedException {
        sem.acquire();
        boolean wasAdded = false;
        try {
            wasAdded = set.add(o);
            return wasAdded;
        } finally {
            if (!wasAdded)
                sem.release();
        }
    }

    public boolean remove(Object o) {
        boolean wasRemoved = set.remove(o);
        if (wasRemoved)
            sem.release();
        return wasRemoved;
    }
}

Semaphore--控制并发线程数

标签：move 数字 thread try obj import and 数据库连接 ret

原文地址：https://www.cnblogs.com/sulishihupan/p/14352411.html

上一篇：springboot基础配置-->Properties配置

下一篇：python 输出latex字符串为数学公式

文章来自：搜素材网的编程语言模块，转载请注明文章出处。
文章标题：Semaphore--控制并发线程数
文章链接：http://soscw.com/index.php/essay/59957.html

亲，登录后才可以留言！

Semaphore--控制并发线程数

评论

热门文章

推荐文章

最新文章

置顶文章