专栏首页Java编程技术Druid连接池原理学习

Druid连接池原理学习

翻了下之前记得笔记,发现有个对druid线程池的概要介绍,下面分析给大家

一、数据库连接池初始化

screenshot.png

(1)、 如果设置了maxWait或者构造函数参数传入的为true,则创建的ReentrantLock为公平锁,否者为非公平锁 (2)、 如果设置了initialSize>=1,则会启动是创建initialSize个数数据库物理连接到线程池。 (3)、 如果没设置createScheduler则创建并启动数据库连接创建线程,如果没设置destroyScheduler则创建并启动数据库连接回收线程,如果timeBetweenLogStatsMillis>0则创建logstat线程。

阿里巴巴长期招聘Java研发工程师p6,p7,p8等上不封顶级别,有意向的可以发简历给我,注明想去的部门和工作地点:1064454834@qq.com

二、获取数据库连接

screenshot.png

(1)、 如果当前数据库连接池有可用连接,则直接获取,否者如果设置createScheduler则开启一个新线程去创建物理连接,否者发送发送signal信号唤醒连接创建线程创建数据库物理连接,这种情况有分pollLast和takeLast,区别在于前者设置max wait超时时间,如果在时间内还没获取链接则返回null,后者则一直等待连接创建。

三、回收数据库连接

screenshot.png

(1)、 在调用conn.close时候会回收当前连接到线程池

四、创建数据库连接线程

screenshot.png

(1)、此图createScheduler=null的情况,为null从上面知道在初始化时候会新建 一个数据库连接创建线程。

五、连接池同步策略

实际上是个生产者消费者模式,生产者是连接创建线程和连接回收线程,消费者是获取连接的线程。 首先列下同步需要的条件变量和锁:

 //独占锁(用来控制同是只有一个线程访问线程池),根据lockFair分为公平和非公平锁
 lock     = new ReentrantLock(lockFair);
 
 //用来对消费和生成线程做同步
 notEmpty = lock.newCondition();
 empty    = lock.newCondition();
 
 //共享资源,线程池是一个数组
 connections = new DruidConnectionHolder[maxActive];

消费者(获取数据库连接线程):

DruidConnectionHolder pollLast(){
    
    DruidConnectionHolder holder;

    try {
            //加独占锁
            lock.lockInterruptibly();
        } catch (InterruptedException e) {
            connectErrorCount.incrementAndGet();
            throw new SQLException("interrupt", e);
    }

    try {

        //通知连接创建线程,创建数据库连接
        empty.signal();

        //等待连接创建线程或者连接回收线程发送信号
        estimate = notEmpty.awaitNanos(estimate);

        //获取链接,并返回
        decrementPoolingCount();
        holder = connections[poolingCount];
        connections[poolingCount] = null;
   

    }finally{
        //释放独占锁
        lock.unlock();

    }


    holder.incrementUseCount();
    DruidPooledConnection poolalbeConnection = new DruidPooledConnection(holder);

    return poolalbeConnection;
}

生产者(连接创建线程):

public void run(){
    try {
        //独占锁
        lock.lockInterruptibly();
    } catch (InterruptedException e2) {
        break;
    }

    try {
        // 必须存在线程等待,才创建连接
        if (poolingCount >= notEmptyWaitThreadCount) {
            empty.await();//会释放当前独占锁

        }

        // 防止创建超过maxActive数量的连接
        if (activeCount + poolingCount >= maxActive) {
            empty.await();//会释放当前独占锁
        }
    } finally {
        lock.unlock();
    }

    Connection connection = null;

    try {
        //创建物理链接
        connection = createPhysicalConnection();
    } catch (SQLException e) {
        。。。。
    } catch (RuntimeException e) {
        。。。。
    } catch (Error e) {
        。。。。
    }


    lock.lock();
    try {
        //连接入池
        connections[poolingCount] = holder;
        incrementPoolingCount();

        if (poolingCount > poolingPeak) {
            poolingPeak = poolingCount;
            poolingPeakTime = System.currentTimeMillis();
        }

        //发出信号,激活消费线程
        notEmpty.signal();
        notEmptySignalCount++;

    } finally {
        lock.unlock();
    }


}

生产者(数据库连接回收线程):

protected void recycle(DruidPooledConnection pooledConnection){
    lock.lockInterruptibly();
    try {
        activeCount--;
        closeCount++;

        connections[poolingCount] = e;
        incrementPoolingCount();

        if (poolingCount > poolingPeak) {
            poolingPeak = poolingCount;
            poolingPeakTime = lastActiveTimeMillis;
        }

        //激活消费线程
        notEmpty.signal();
        notEmptySignalCount++;      
        recycleCount++;
    } finally {
        lock.unlock();
    }
}

本文参与腾讯云自媒体分享计划,欢迎正在阅读的你也加入,一起分享。

我来说两句

0 条评论
登录 后参与评论

相关文章

  • Go并发编程之美-条件变量

    go语言类似Java JUC包也提供了一些列用于多线程之间进行同步的措施,比如低级的同步措施有 锁、CAS、原子变量操作类。相比Java来说go提供了独特的基于...

    加多
  • Go并发编程之美-条件变量

    go语言类似Java JUC包也提供了一些列用于多线程之间进行同步的措施,比如低级的同步措施有 锁、CAS、原子变量操作类。相比Java来说go提供了独特的基于...

    加多
  • 使用数据库悲观锁实现不可重入的分布式锁

    在同一个jvm进程中时,可以使用JUC提供的一些锁来解决多个线程竞争同一个共享资源时候的线程安全问题,但是当多个不同机器上的不同jvm进程共同竞争同一个共享资源...

    加多
  • Python多线程机制

    今天要跟大家一起来学习一下Python的多线程机制。有两个原因,其一是自己在学习中经常会使用到多线程,其二当然是自己对Python中的多线程并不是很了解。那么,...

    oYabea
  • 慕课网高并发实战(一)-并发与高并发基本概念

    Meet相识
  • java高并发系列 - 第13天:JUC中的Condition对象

    Object对象中的wait(),notify()方法,用于线程等待和唤醒等待中的线程,大家应该比较熟悉,想再次了解的朋友可以移步到java高并发系列 - 第6...

    路人甲Java
  • 浅谈JS线程

    线程,对于后端的人来讲是很熟悉的,对于前端,却基本不会注意到。我们都知道JavaScript是单线程的,也就是说,同一个时间只能做一件事。说是为了避免复杂性,所...

    wade
  • 《快学 Go 语言》第 11 课 —— 千军万马跑协程

    协程和通道是 Go 语言作为并发编程语言最为重要的特色之一,初学者可以完全将协程理解为线程,但是用起来比线程更加简单,占用的资源也更少。通常在一个进程里启动上万...

    老钱
  • yaffsfs.c

    1.int yaffs_write(int fd, const void *buf, unsigned int nbyte)如果一个需要写入文件大于一个chun...

    瓜大三哥
  • 深入浅出JVM的锁优化案例锁优化

    线程阻塞的时候,让等待的线程不放弃cpu执行时间,而是执行一个自旋(一般是空循环),这叫做自旋锁。

    美的让人心动

扫码关注云+社区

领取腾讯云代金券