Class ConcurrentBuffer

Source/Engine/Threading/ConcurrentBuffer.h:16–400

/// </summary>
template<typename T>
class ConcurrentBuffer
{
    friend ConcurrentBuffer;

private:

    int64 _count;
    int64 _capacity;
    T* _data;
    CriticalSection _resizeLocker;

public:

    /// <summary>
    /// Initializes a new instance of the <see cref="ConcurrentBuffer"/> class.
    /// </summary>
    ConcurrentBuffer()
        : _count(0)
        , _capacity(0)
        , _data(nullptr)
    {
    }

    /// <summary>
    /// Initializes a new instance of the <see cref="ConcurrentBuffer"/> class.
    /// </summary>
    /// <param name="capacity">The capacity.</param>
    ConcurrentBuffer(int32 capacity)
        : _count(0)
        , _capacity(capacity)
    {
        if (_capacity > 0)
            _data = (T*)Allocator::Allocate(_capacity * sizeof(T));
        else
            _data = nullptr;
    }

    /// <summary>
    /// Finalizes an instance of the <see cref="ConcurrentBuffer"/> class.
    /// </summary>
    ~ConcurrentBuffer()
    {
        Allocator::Free(_data);
    }

public:

    /// <summary>
    /// Gets the amount of the elements in the collection.
    /// </summary>
    /// <returns>The items count.</returns>
    FORCE_INLINE int64 Count()
    {
        return Platform::AtomicRead(&_count);
    }

    /// <summary>
    /// Get amount of the elements that can be holed by collection without resizing.