java中的同步辅助

Question

我正在运行一个网络服务器。每个用户请求都会更新/查找数据库。同时数据库连接的最大数量应小于等于N.第N+1个并发请求应该退出并执行其他逻辑，而不是连接到数据库。我能想到的做法是使用原子整数，在连接到数据库时，该整数将根据每个请求递增/递减。

我的问题是，除了原子整数之外，java 中是否还有其他可用的同步辅助工具？我认为我不能为此使用 CountDownLatch 或循环屏障。

Answer 1

信号量 是最适合这种情况的同步原语：

private Semaphore s = new Semaphore(N);

public void doRequest() {
    if (s.tryAquire()) {
        try {
            ...
        } finally {
            s.release();
        }
    } else {
        // other logic
    }
}

Answer 2

您可以尝试 ArrayBlockingQueue连接数。用 N 初始化队列。

1. 用 N 初始化队列
2. 填充 N 个连接。
3. 每当有人需要连接时，首先执行 q.poll()
4. 如果 q.poll() 返回 null，则执行“执行其他逻辑”
5. 使用后将连接放回池中。

但我强烈建议使用现有的解决方案，例如 proxool 。

Answer 3

或者，您可以使用连接池，例如 Apache Commons DBCP，它将为您处理连接，并且可以等待对于没有连接或将抛出您可以处理的异常的连接。

Answer 4

添加到suraj的答案中，我认为您的问题更多是生产者消费者，我更喜欢LinkedBlockingQueue以获得更高的吞吐量。