ObjectPool.h

Go to the documentation of this file.

 
#ifndef ETISS_OBJECTPOOL_H_
#define ETISS_OBJECTPOOL_H_
 
#include "etiss/Misc.h"
#include "etiss/RefCountedObject.h"
 
#include <cstring>
 
#define ETISS_OBJECTPOOL_LOGSIZE 1
#define ETISS_OBJECTPOOL_DBG_OBJLIMIT 0 // set to 0 to disable
 
namespace etiss
{
 
template <typename T, size_t prealloc_inc = 100>
class ObjectPool;
 
namespace internal
{
// functions to set a pointer from object to memory pool if object inherited
// RefCounted Object
template <typename T>
typename std::enable_if<!std::is_base_of<etiss::RefCountedObject<ObjectPool<T>>, T>::value, void>::type
ObjectPool_setAllocatorPointer(T *obj, ObjectPool<T> *this_)
{
}
template <typename T>
typename std::enable_if<std::is_base_of<etiss::RefCountedObject<ObjectPool<T>>, T>::value, void>::type
ObjectPool_setAllocatorPointer(T *obj, ObjectPool<T> *this_)
{
    etiss::helper_allocator_ptr_ref<T, ObjectPool<T>>(obj) = this_;
}
} // namespace internal
 
// patch missing alignof support for msvc
#ifdef _MSC_VER
#define alignof(x) __alignof(x)
#endif
template <typename T, size_t prealloc_inc>
class ObjectPool
{
  public:
    const size_t blocksize_;
 
  private:
    std::set<void *> areas_;
    std::vector<void *> empty_;
 
  public:
    typedef T value_type;
    typedef T *pointer;
    typedef const T *const_pointer;
    typedef T &reference;
    typedef const T &const_reference;
 
    typedef typename std::aligned_storage<sizeof(T), alignof(T)>::type storage;
 
  private:
    storage stackstore[prealloc_inc]; // small (fast) possibly stack allocation of the first elements
    bool stackstore_used;
 
  public:
    template <class Type>
    struct rebind
    {
        typedef ObjectPool<Type> other;
    };
 
    ObjectPool(size_t blockElementCount = 5000) : blocksize_(blockElementCount), stackstore_used(false) {}
    ObjectPool(const ObjectPool &alloc) : blocksize_(alloc.blocksize_), stackstore_used(false) {}
    template <class U>
    ObjectPool(const ObjectPool<U> &alloc) : blocksize_(alloc.blocksize_), stackstore_used(false)
    {
    }
    ~ObjectPool()
    {
        // no other cleanup must be preformed since all allocated objects are required to be destroyed prior to this
        // destruction
        for (auto iter = areas_.begin(); iter != areas_.end(); ++iter)
            if (*iter != stackstore)
                delete[](storage *)(*iter);
    }
 
    T *address(T &x) const { return &x; }
    const T *address(const T &x) const { return &x; }
    T *allocate(size_t n = 1, const T * = 0)
    {
        if (unlikely(n <= 0))
            throw std::bad_alloc();
        if (unlikely(n > 1)) // fall back to simple malloc call
        {
            return (T *)new storage[n];
        }
        else
        {
            if (unlikely(empty_.empty()))
            {
                if (!stackstore_used)
                {
                    stackstore_used = true;
                    for (size_t i = 0; i < prealloc_inc; ++i)
                    {
                        empty_.push_back((void *)(&(stackstore[i])));
                    }
                }
                else
                {
                    storage *area = new storage[blocksize_];
                    if (area == 0)
                        throw std::bad_alloc();
                    areas_.insert(area);
#if ETISS_OBJECTPOOL_DBG_OBJLIMIT
                    if (areas_.size() * blocksize_ > ETISS_OBJECTPOOL_DBG_OBJLIMIT)
                        throw new std::bad_alloc();
#endif
                    for (size_t i = 0; i < blocksize_; ++i)
                    {
                        empty_.push_back((void *)(&(area[i])));
                    }
#if ETISS_OBJECTPOOL_LOGSIZE
                    // etiss::log(etiss::VERBOSE,"ObjectPool increased size",areas_.size()*blocksize_+100);
#endif
                }
            }
            void *area = empty_.back();
            empty_.pop_back();
            return (T *)area;
        }
    }
    void deallocate(T *p, size_t n = 1)
    {
        if (unlikely(p == 0))
            return;
        if (unlikely(n <= 0))
            throw std::bad_alloc();
        if (unlikely(n > 1))
        {
            delete[](storage *) p;
        }
        else
        {
            empty_.push_back(p);
        }
    }
    size_t max_size() const { return (size_t)-1; }
    template <class U, class... Args>
    void construct(U *p, Args &&... args)
    {
        ::new ((void *)p) U(std::forward<Args>(args)...);
        etiss::internal::ObjectPool_setAllocatorPointer<T>((T *)p, this);
    }
    template <class U>
    void destroy(U *p)
    {
        p->~U();
    }
};
 
template <typename T>
typename std::enable_if<std::is_base_of<etiss::RefCountedObject<ObjectPool<T>>, T>::value, bool>::type decRef(T *ptr)
{
    bool ret = helper_decRef<T, typename T::refcount_allocatorT>(ptr);
    if (ret)
    {
        ObjectPool<T> *&pool = etiss::helper_allocator_ptr_ref<T, typename T::refcount_allocatorT>(ptr);
#if DEBUG
        if (pool == 0)
            throw std::bad_alloc();
#endif
        pool->destroy(ptr);
        pool->deallocate(ptr);
        ptr = 0;
    }
    return ret;
}
 
template <typename T, size_t stackallocatedsize = 1>
class ExpandingNativeStack
{
    static_assert(std::is_pod<T>::value, "ExpandingNativeStack can only handle types without constructor/destructor. "
                                         "This cannot be fullfilled by non POD objects");
 
  private:
    T stackbuf_[stackallocatedsize > 0 ? stackallocatedsize : 1]; // must be >0 to conform to c++ standard
    T *stack_;
    size_t size_;
    ssize_t pos_;
 
  public:
    ExpandingNativeStack() : stack_(stackbuf_), size_(stackallocatedsize > 0 ? stackallocatedsize : 1), pos_(-1) {}
    ~ExpandingNativeStack()
    {
        if (stack_ != stackbuf_)
            delete stack_;
    }
    inline T operator[](ssize_t pos)
    {
#if DEBUG
        if (unlikely((pos >= size_) || pos < 0))
            etiss::log(etiss::FATALERROR, "Array index out of bounds", pos, ETISS_SRCLOC);
#endif
        return stack_[pos];
    }
    inline const T operator[](size_t pos) const
    {
#if DEBUG
        if (unlikely((pos >= size_) || pos < 0))
            etiss::log(etiss::FATALERROR, "Array index out of bounds", pos, ETISS_SRCLOC);
#endif
        return stack_[pos];
    }
    inline ssize_t pos() const { return pos_; }
    inline ssize_t size() const { return pos_ + 1; }
    inline ssize_t capacity() const { return size_; }
    inline T &back() { return stack_[pos_]; }
    inline const T &back() const { return stack_[pos_]; }
    inline T &front() { return stack_[0]; }
    inline const T &front() const { return stack_[0]; }
    inline void pop()
    {
#if DEBUG
        if (unlikely(pos_ < 0))
            etiss::log(etiss::FATALERROR, "Array index out of bounds (negative)", ETISS_SRCLOC);
#endif
        --pos_;
    }
    inline void push(T t)
    {
        if (unlikely((++pos_) == (ssize_t)size_)) // reached end of old stack
        {
            size_t new_size = size_ + 10 + (size_ / 20); // increase stack size
            T *tmp = new T[new_size];                    // allocate new stack
            memcpy(tmp, stack_, size_ * sizeof(T));      // copy old elements
            if (stack_ != stackbuf_)
                delete[] stack_;
            stack_ = tmp;
            size_ = new_size;
        }
        stack_[pos_] = t;
    }
    inline bool empty() const { return pos_ < 0; }
};
 
} // namespace etiss
 
#endif