Java--對象池化技術 org.apache.commons.pool2.ObjectPool，apachecommonspool

Java--對象池化技術 org.apache.commons.pool2.ObjectPool，apachecommonspool

org.apache.commons.pool2.ObjectPool提供了對象池，開發的小伙伴們可以直接使用來構建一個對象池

使用該對象池具有兩個簡單的步驟：

1、創建對象工廠，org.apache.commons.pool2.BasePooledObjectFactory已經對工廠有抽象實現，所以只需要繼承該類，實現模板方法即可

package com.seeyon.objectPool;

import org.apache.commons.pool2.BasePooledObjectFactory;
import org.apache.commons.pool2.PooledObject;
import org.apache.commons.pool2.impl.DefaultPooledObject;

/**
 * Created by yangyu on 16/12/26.
 */

/**
 * 對象工廠，用於創建對象
 */
public class ObjectFactory extends BasePooledObjectFactory<ObjectFactory.Computer> {


    /**
     * 創建對象，返回你需要的對象實例就可以啦
     * @return
     * @throws Exception
     */
    @Override
    public Computer create() throws Exception {
        return new Computer("mac");
    }

    /**
     * 包裝對象，將對象包裝為PooledObject
     * @param obj
     * @return
     */
    @Override
    public PooledObject<Computer> wrap(Computer obj) {
        return new DefaultPooledObject<>(obj);
    }

    public class Computer{

        String name;

        public Computer(String name){
            this.name = name;
        }
    }
}

2、使用對象池

package com.seeyon.objectPool;

import org.apache.commons.pool2.ObjectPool;
import org.apache.commons.pool2.impl.GenericObjectPool;

/**
 * Created by yangyu on 16/12/26.
 */

/**
 * org.apache.commons.pool2.ObjectPool對象池的使用
 * 直接apache使用對象池，可以實現對象池化技術
 */
public class TestObjectPool {
    public static void main(String[] args) throws InterruptedException {
        /**
         * 創建對象工廠
         */
        ObjectFactory objectFactory = new ObjectFactory();
        /**
         * 創建一個普通的對象池
         */
        ObjectPool<ObjectFactory.Computer> objectPool = new GenericObjectPool(objectFactory);

        /**
         * 創建第一個線程
         */
        Thread t1 = new Thread(() -> {
            try {
                /**
                 * 從對象池中獲取對象
                 */
                ObjectFactory.Computer computer = objectPool.borrowObject();
                System.out.println(Thread.currentThread().getId() + ":" + computer);
                /**
                 * 用完後將對象放回對象池中
                 */
                objectPool.returnObject(computer);
            } catch (Exception e) {
                e.printStackTrace();
            }
        });

        t1.start();
        t1.join();

        new Thread(() -> {
            try {
                /**
                 * 再次從對象池中獲取對象，你會發現獲取的是同一個對象，說明對象池化技術成功
                 */
                System.out.println(Thread.currentThread().getId() + ":" + objectPool.borrowObject());
            } catch (Exception e) {
                e.printStackTrace();
            }
        }).start();

    }
}

3、輸出結果：可以看到兩個線程一先一後，使用的同一個對象，池化技術使用完成。

11:com.seeyon.objectPool.ObjectFactory$Computer@4e72fd4
12:com.seeyon.objectPool.ObjectFactory$Computer@4e72fd4