对象池common-pool2源码分析
博客专区 > udbwcso 的博客 > 博客详情
对象池common-pool2源码分析
udbwcso 发表于2年前
对象池common-pool2源码分析
  • 发表于 2年前
  • 阅读 243
  • 收藏 6
  • 点赞 1
  • 评论 0

标题:腾讯云 新注册用户域名抢购1元起>>>   

摘要: common-pool2源码分析

Apache common-pool2提供了一个通用的对象池技术的实现。

common-pool2主要围绕三个接口来实现,ObjectPool、PooledObject、PooledObjectFactory。由PooledObjectFactory创建的对象,经PooledObject包装后放入ObjectPool。

1.ObjectPool对象池

ObjectPool:对象池,负责存放管理对象.

官方例子:http://commons.apache.org/proper/commons-pool/examples.html

ReaderUtil readerUtil = 
        new ReaderUtil(new GenericObjectPool<StringBuffer>(new StringBufferFactory()));

先从GenericObjectPool开始分析

成员变量:

重要的成员变量为:allObjects和idleObjects.

/*
 * All of the objects currently associated with this pool in any state. It
 * excludes objects that have been destroyed. The size of
 * {@link #allObjects} will always be less than or equal to {@link
 * #_maxActive}. Map keys are pooled objects, values are the PooledObject
 * wrappers used internally by the pool.
 */
private final Map<T, PooledObject<T>> allObjects =
        new ConcurrentHashMap<T, PooledObject<T>>();


private final LinkedBlockingDeque<PooledObject<T>> idleObjects;


allObjects:对象池中所有的对象.

idleObjects:空闲对象.

其中数据结构LinkedBlockingDeque:

结点的数据结构

/** Doubly-linked list node class */
private static final class Node<E> {
    /**
     * The item, or null if this node has been removed.
     */
    E item;

    /**
     * One of:
     * - the real predecessor Node
     * - this Node, meaning the predecessor is tail
     * - null, meaning there is no predecessor
     */
    Node<E> prev;

    /**
     * One of:
     * - the real successor Node
     * - this Node, meaning the successor is head
     * - null, meaning there is no successor
     */
    Node<E> next;

    /**
     * Create a new list node.
     *
     * @param x The list item
     * @param p Previous item
     * @param n Next item
     */
    Node(E x, Node<E> p, Node<E> n) {
        item = x;
        prev = p;
        next = n;
    }
}

2.PooledObject池对象

PooledObject:池对象,将需要放入对象池的对象包装添加一些附加信息.

从之前的分析中可以看出GenericObjectPool中allObjects和idleObjects存放均是池对象即经过包装的对象.

private final Map<T, PooledObject<T>> allObjects =
        new ConcurrentHashMap<T, PooledObject<T>>();
private final LinkedBlockingDeque<PooledObject<T>> idleObjects;

3.PooledObjectFactory池对象工厂

PooledObjectFactory:池对象工厂,负责池对象的创建,销毁等.

共有 人打赏支持
粉丝 72
博文 34
码字总数 15570
×
udbwcso
如果觉得我的文章对您有用,请随意打赏。您的支持将鼓励我继续创作!
* 金额(元)
¥1 ¥5 ¥10 ¥20 其他金额
打赏人
留言
* 支付类型
微信扫码支付
打赏金额:
已支付成功
打赏金额: