Class queue

src/backend/cpu/queue.hpp:91–131

Wraps the async_queue class

/// Wraps the async_queue class
class queue {
   public:
    queue()
        : count(0)
        , sync_calls(__SYNCHRONOUS_ARCH == 1 ||
                     common::getEnvVar("AF_SYNCHRONOUS_CALLS") == "1") {}

    template<typename F, typename... Args>
    void enqueue(const F func, Args &&...args) {
        count++;
        if (sync_calls) {
            func(toParam(std::forward<Args>(args))...);
        } else {
            aQueue.enqueue(func, toParam(std::forward<Args>(args))...);
        }
#ifndef NDEBUG
        sync();
#else
        if (getMemoryPressure() >= getMemoryPressureThreshold() ||
            count >= 25) {
            sync();
        }
#endif
    }

    void sync() {
        count = 0;
        if (!sync_calls) aQueue.sync();
    }

    bool is_worker() const {
        return (!sync_calls) ? aQueue.is_worker() : false;
    }

    friend class queue_event;

   private:
    int count;
    const bool sync_calls;
    queue_impl aQueue;
};

class queue_event {
    event_impl event_;