front::bonqueue< T, N > Class Template Reference

#include <SignalVk.h>

Public Member Functions
void	reset ()
void	push (T val)
T	nip ()

Public Attributes
std::queue< T >	queue_
uint32_t	consume = 0
uint32_t	produce = 0

Detailed Description

template<typename T, size_t N>
class front::bonqueue< T, N >

Definition at line 20 of file SignalVk.h.

Member Function Documentation

nip()

template<typename T , size_t N>

T front::bonqueue< T, N >::nip ( )

inline

uint32_t p = produce.load(); uint32_t c = consume.load();

Definition at line 71 of file SignalVk.h.

                  {
          
            std::unique_lock<std::mutex> lk(guard_);
 
            sig_push.wait(lk, [this] {
 
                return !queue_.empty();
                });
 
            T ret = std::move(queue_.front());
            queue_.pop();
            if (ret != -1)InterlockedExchangeAdd((long*)&consume, 1);
            sig_pop.notify_all();
 
            return ret;
        };

push()

template<typename T , size_t N>

void front::bonqueue< T, N >::push ( T  val )

inline

static std::mutex guard_; static std::atomic_uint sigs = 0;

{0}

log_warning("notify ============== = > notify signal not_full BonQueue Over limit. %zu \n", size);

uint32_t nums = sigs.fetch_add(1);

Definition at line 43 of file SignalVk.h.

                         {
            std::unique_lock<std::mutex> lk(guard_);   
            sig_pop.wait(lk, [this] {
                size_t size = queue_.size();
 
                if (size > N) {
                    sig_push.notify_all();
                    return false;
                }
                return true;
             });
 
            queue_.push(std::move(val));
            if (val != -1)InterlockedExchangeAdd((long*)&produce, 1);
 
 
            //std::this_thread::sleep_for(std::chrono::nanoseconds(10));
 
            sig_push.notify_one();
 
 
 
        }

reset()

template<typename T , size_t N>

void front::bonqueue< T, N >::reset ( )

inline

Definition at line 33 of file SignalVk.h.

                     {
            consume = 0;
            produce = 0;
            while (queue_.size()) {
                T ret = std::move(queue_.front());
                log_warning(" bonqueue reset::  last of buds. [%d] \n ", (int)ret);
                queue_.pop();
            }
        };

Member Data Documentation

consume

template<typename T , size_t N>

uint32_t front::bonqueue< T, N >::consume = 0

Definition at line 30 of file SignalVk.h.

produce

template<typename T , size_t N>

uint32_t front::bonqueue< T, N >::produce = 0

Definition at line 31 of file SignalVk.h.

queue_

template<typename T , size_t N>

std::queue<T> front::bonqueue< T, N >::queue_

Definition at line 29 of file SignalVk.h.

---

The documentation for this class was generated from the following file:

• SignalVk.h