The asynchrony-lib from siddiqsoft

siddiqsoft / asynchrony-lib Goto Github PK

View Code? Open in Web Editor NEW

Classes to allow you to build asynchrony in your applications using standard C++ jthread, semaphore, deque

License: BSD 3-Clause "New" or "Revised" License

C++ 100.00%

asynchrony-lib's People

Contributors

asynchrony-lib's Issues

Add timer utility

Add a simple periodic timer utility.

Rename the structs

The use of names 'basic_*' is confusing with the std naming.
Rename the structs to avoid any confusion.

simple_pool does not handle structs

Structs with implicitly deleted copy constructors fail to compile. There is a needless copy during pop from queue.

The compiler reports no appropriate default constructor available.
The culprit is here in the thread worker loop code:

    if (signal.try_acquire_for(signalWaitInterval)) {
        // Guard against empty signals which are terminating indicator
        if (!items.empty() && !st.stop_requested()) {
            T item;

            { // scope lock to pull item from the deque
                std::unique_lock<std::shared_mutex> myWriterLock(items_mutex);
                item = items.front();
                items.pop_front();
            } // end of lock
            // Delegate to the callback outside the lock
            callback(item);
        }
    }

The fact that we use T item; requires that the object be default constructible whereas our only real requirement is the object type be move constructible.

Recommend Projects