5.如何控制数据库连接池并发数-Semaphore

Java 的并发包下,提供一个工具类:Semaphore,可用于控制并发数量,即同时访问特定资源的线程数量,通过协调各个线程,保证合理使用公共资源。
比如以数据库连接池为例,现有30个线程请求数据库连接,但连接池的最大连接数为10,故会有20个线程请求失败。为控制连接数,可用Semaphore操作。

Semaphore 中有个计数器,表示可用的许可证数量。 调用acquire()方法,可以获取许可证,使用完后调用release()方法,释放许可证。

package com.myConcurrent.demo.concurrentUtils;

import java.util.concurrent.Semaphore;

/**
 * @author fenghongyu
 * 控制线程的并发连接数
 */
public class SemaphoreDemo {

    public void controlConnectionNum() {
        int maxConnectionNum = 10;
        int threadNum = 30;
        Semaphore semaphore = new Semaphore(maxConnectionNum);

        for(int i=0;i<threadNum;i++) {
            new Thread(() -> {
                try {
                    semaphore.acquire();
                    System.out.println("--------connection to mysql");
                    Thread.sleep(1000);
                    semaphore.release();
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }
            }).start();
        }
    }

    public static void main(String[] args) {
        SemaphoreDemo demo = new SemaphoreDemo();
        demo.controlConnectionNum();
    }
}

©著作权归作者所有,转载或内容合作请联系作者
【社区内容提示】社区部分内容疑似由AI辅助生成,浏览时请结合常识与多方信息审慎甄别。
平台声明:文章内容(如有图片或视频亦包括在内)由作者上传并发布,文章内容仅代表作者本人观点,简书系信息发布平台,仅提供信息存储服务。

相关阅读更多精彩内容

友情链接更多精彩内容