Function TEST

test/core/test_taskqueue.cpp:8–34

#include "../../src/core/taskqueue.hpp"

TEST(TaskQueue, Cancel) {
    pop::TaskQueue<int> queue;
    std::mutex mutex;
    std::unique_lock lock(mutex);
    std::condition_variable cvStarted;
    std::condition_variable cvDone;
    const size_t first = queue.enqueue([&mutex, &cvStarted, &cvDone] {
        std::unique_lock firstLock(mutex);
        cvStarted.notify_all();
        EXPECT_EQ(cvDone.wait_for(firstLock, std::chrono::seconds(1)), std::cv_status::no_timeout);
        return 1;
    });
    EXPECT_FALSE(queue.cancel(first)); // about to start
    // ^ This is an implementation detail, but covers an additional branch.
    // Note: after the second enqueue, cancel(first) may succeed
    const size_t second = queue.enqueue([] {
        return 2;
    });
    ASSERT_EQ(cvStarted.wait_for(lock, std::chrono::seconds(1)), std::cv_status::no_timeout);
    EXPECT_FALSE(queue.cancel(first)); // already running
    EXPECT_TRUE(queue.cancel(second)); // ok, not running
    EXPECT_FALSE(queue.cancel(second)); // already canceled
    cvDone.notify_all();
    lock.unlock();
    queue.get(first);
    EXPECT_FALSE(queue.cancel(first)); // already finished
}

TEST(TaskQueue, TryGet) {
    pop::TaskQueue<int> queue;