util/generic/fastqueue.h


1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54

#pragma once 
 
#include <util/memory/smallobj.h> 
#include "ptr.h"
 
template <class T> 
class TFastQueue { 
    struct THelper: public TObjectFromPool<THelper>, public TIntrusiveListItem<THelper> { 
        inline THelper(const T& t) 
            : Obj(t) 
        { 
        } 
 
        T Obj; 
    }; 
 
public: 
    inline TFastQueue() 
        : Pool_(TDefaultAllocator::Instance()) 
        , Size_(0) 
    { 
    } 
 
    inline void Push(const T& t) { 
        Queue_.PushFront(new (&Pool_) THelper(t)); 
        ++Size_; 
    } 
 
    inline T Pop() { 
        Y_ASSERT(!this->Empty());
 
        THolder<THelper> tmp(Queue_.PopBack()); 
        --Size_; 
 
        return tmp->Obj; 
    } 
 
    inline size_t Size() const noexcept {
        return Size_; 
    } 
 
    Y_PURE_FUNCTION inline bool Empty() const noexcept {
        return !this->Size(); 
    } 
 
    inline explicit operator bool() const noexcept {
        return !this->Empty();
    }

private: 
    typename THelper::TPool Pool_; 
    TIntrusiveListWithAutoDelete<THelper, TDelete> Queue_; 
    size_t Size_; 
};