// • ▌ ▄ ·.  ▄▄▄·  ▄▄ • ▪   ▄▄· ▄▄▄▄·  ▄▄▄·  ▐▄▄▄  ▄▄▄ .
// ·██ ▐███▪▐█ ▀█ ▐█ ▀ ▪██ ▐█ ▌▪▐█ ▀█▪▐█ ▀█ •█▌ ▐█▐▌·
// ▐█ ▌▐▌▐█·▄█▀▀█ ▄█ ▀█▄▐█·██ ▄▄▐█▀▀█▄▄█▀▀█ ▐█▐ ▐▌▐▀▀▀
// ██ ██▌▐█▌▐█ ▪▐▌▐█▄▪▐█▐█▌▐███▌██▄▪▐█▐█ ▪▐▌██▐ █▌▐█▄▄▌
// ▀▀  █▪▀▀▀ ▀  ▀ ·▀▀▀▀ ▀▀▀·▀▀▀ ·▀▀▀▀  ▀  ▀ ▀▀  █▪ ▀▀▀
//      Magicbane Emulator Project © 2013 - 2022
//                www.magicbane.com


package engine.pooling;

import org.pmw.tinylog.Logger;

import java.util.ArrayList;

public abstract class ObjectPool<T> {
    protected final static int DEFAULT_SIZE = 1000;

    // Simple + quick list
    private final ArrayList<T> pool;

    /**
     * Once the ArrayList fills to <b>threshold</b>, subsequent .put() calls
     * result in the object being thrown away. Default is 75% of supplied
     * <b>size</b>.
     */
    private int threshold;

    /**
     * Constructor that allows the caller to specify initial array size and
     * percent of prefill.
     *
     * @param size - initial size for the containing array (pool)
     */
    public ObjectPool(int size) {
        if (size == 0) {
            size = DEFAULT_SIZE;
        }

        threshold = (int) (0.75 * size);

        this.pool = new ArrayList<>(size);

    }

    /**
     * Default Constructor that uses default initial Array size and percent
     * prefill values
     */
    public ObjectPool() {
        this(DEFAULT_SIZE);
    }

    /**
     * Forces pool to add <i>numberOfObjects</i> to the pool. This may cause
     * internal ArrayList to resize.
     *
     * @param numberOfObjects
     */
    public void fill(int numberOfObjects) {
        for (int i = 0; i < numberOfObjects; ++i)
            this.makeAndAdd();
    }

    /**
     * Forces subclasses to implement factory routine for object creation.
     */
    protected abstract T makeNewObject();

    /**
     * Forces subclasses to implement a way to reset object to a reusable state.
     */
    protected abstract void resetObject(T obj);

    /**
     * Generic Get routine. If the pool is empty, then one (or more) of T type
     * objects will be created. If more than one T is created, then they will be
     * put into the pool. One T will always be created and returned.
     */
    public T get() {
        synchronized (pool) {
            //Logger.debug("Objectpool.get().  Pool size before get: " + pool.size());
            if (pool.size() > 0) {
                return pool.remove(0);
            }
        }

        this.handlePoolExhaustion();

        T obj = this.makeNewObject();

        if (obj == null) {
            Logger.error("Pooling failure: Object creation failed.");
        }
        return obj;
    }

    protected void handlePoolExhaustion() {
        Logger.debug("Pool exhausted, making more objects.");

        // If none exist, make (and pool) a few
        // Dont sync the loop, let the makeNewObject()
        // call return before locking the pool object
        for (int i = 0; i < 5; ++i)
            this.makeAndAdd();

    }

    /**
     * Generic put routine. If the current pool size is below threshold, this
     * object will be pooled, otherwise it will be NULL'ed and scheduled for
     * Garbage Collection
     *
     * @param obj
     */
    public void put(T obj) {
        synchronized (pool) {
            if (pool.size() >= this.threshold) {
                //Logger.debug("Objectpool.put() rejected.  Pool size: " + pool.size());
                return;
            }
            //Logger.debug("Objectpool.put().  Pool size: " + pool.size());
            this.resetObject(obj);
            this.pool.add(obj);
        }
    }

    /**
     * Helper method. Attempts to create and add a new <i>T</i> object. If this
     * fails, an error is logged.
     */
    protected final void makeAndAdd() {
        T obj = this.makeNewObject();
        if (obj == null) {
            Logger.error("Pooling failure: Object creation failed.");
        } else {
            this.put(obj);
        }
    }

    /**
     * @return the current size of the pool, not the maximum capacity of the
     * Array holding the pool.
     */
    public final int getPoolSize() {
        synchronized (this.pool) {
            return this.pool.size();
        }
    }

    /**
     * Culls the pool and removes half of the stored objects. Removed objects
     * are NULL'ed and scheduled form Garbage Collection.
     *
     * @return the number of Objects removed from the pool.
     */
    public int cullHalf() {
        int full, half;
        synchronized (this.pool) {
            full = this.pool.size();
            if (full < 1) {
                return full;
            }

            half = (full / 2);

            for (int i = 0; i < (full / 2); ++i) {
                T obj = this.get();
                obj = null; // Null out for GC
            }
        }
        return half;
    }

    /**
     * @return the threshold
     */
    public final int getThreshold() {
        return threshold;
    }

    /**
     * @param threshold the threshold to set
     */
    public void setThreshold(int threshold) {
        if (threshold < 0)
            return;

        this.threshold = threshold;
    }

}