threadpool_tests.cpp File Reference

#include <common/system.h>
#include <logging.h>
#include <random.h>
#include <test/util/common.h>
#include <util/string.h>
#include <util/threadpool.h>
#include <util/time.h>
#include <boost/test/unit_test.hpp>
#include <array>
#include <functional>
#include <latch>
#include <ranges>
#include <semaphore>

Include dependency graph for threadpool_tests.cpp:

Go to the source code of this file.

Classes
struct	ThreadPoolFixture

Macros
#define	WAIT_FOR(futures)

Functions
template<typename F >
auto	Submit (ThreadPool &pool, F &&fn)
std::vector< std::future< void > >	BlockWorkers (ThreadPool &threadPool, std::counting_semaphore<> &release_sem, size_t num_of_threads_to_block)
	BOOST_AUTO_TEST_CASE (submit_fails_with_correct_error)
	BOOST_AUTO_TEST_CASE (submit_tasks_complete_successfully)
	BOOST_AUTO_TEST_CASE (single_available_worker_executes_all_tasks)
	BOOST_AUTO_TEST_CASE (wait_for_task_to_finish)
	BOOST_AUTO_TEST_CASE (get_result_from_completed_task)
	BOOST_AUTO_TEST_CASE (task_exception_propagates_to_future)
	BOOST_AUTO_TEST_CASE (process_tasks_manually_when_workers_busy)
	BOOST_AUTO_TEST_CASE (recursive_task_submission)
	BOOST_AUTO_TEST_CASE (task_submitted_while_busy_completes)
	BOOST_AUTO_TEST_CASE (congestion_more_workers_than_cores)
	BOOST_AUTO_TEST_CASE (interrupt_blocks_new_submissions)
	BOOST_AUTO_TEST_CASE (start_mid_stop_does_not_deadlock)
	BOOST_AUTO_TEST_CASE (queued_tasks_complete_after_interrupt)
	BOOST_AUTO_TEST_CASE (stop_active_wait_drains_queue)
	BOOST_AUTO_TEST_CASE (submit_range_of_tasks_complete_successfully)

Variables
int	NUM_WORKERS_DEFAULT = 0
constexpr char	POOL_NAME [] = "test"
constexpr auto	TEST_WAIT_TIMEOUT = 120s

Macro Definition Documentation

WAIT_FOR

#define WAIT_FOR

(

futures

)

Value:

    do {                                                                          \
        for (const auto& f : futures) {                                           \
            BOOST_REQUIRE(f.wait_for(TEST_WAIT_TIMEOUT) == std::future_status::ready); \
        }                                                                         \
    } while (0)

Definition at line 51 of file threadpool_tests.cpp.

Function Documentation

BlockWorkers()

std::vector< std::future< void > > BlockWorkers	(	ThreadPool &	threadPool,
		std::counting_semaphore<> &	release_sem,
		size_t	num_of_threads_to_block
	)

Definition at line 67 of file threadpool_tests.cpp.

Here is the call graph for this function:

Here is the caller graph for this function:

BOOST_AUTO_TEST_CASE() [1/15]

BOOST_AUTO_TEST_CASE

(

congestion_more_workers_than_cores

)

Definition at line 304 of file threadpool_tests.cpp.

Here is the call graph for this function:

BOOST_AUTO_TEST_CASE() [2/15]

BOOST_AUTO_TEST_CASE

(

get_result_from_completed_task

)

Definition at line 188 of file threadpool_tests.cpp.

Here is the call graph for this function:

BOOST_AUTO_TEST_CASE() [3/15]

BOOST_AUTO_TEST_CASE

(

interrupt_blocks_new_submissions

)

Definition at line 325 of file threadpool_tests.cpp.

Here is the call graph for this function:

BOOST_AUTO_TEST_CASE() [4/15]

BOOST_AUTO_TEST_CASE

(

process_tasks_manually_when_workers_busy

)

Definition at line 221 of file threadpool_tests.cpp.

Here is the call graph for this function:

BOOST_AUTO_TEST_CASE() [5/15]

BOOST_AUTO_TEST_CASE

(

queued_tasks_complete_after_interrupt

)

Definition at line 393 of file threadpool_tests.cpp.

Here is the call graph for this function:

BOOST_AUTO_TEST_CASE() [6/15]

BOOST_AUTO_TEST_CASE

(

recursive_task_submission

)

Definition at line 252 of file threadpool_tests.cpp.

Here is the call graph for this function:

BOOST_AUTO_TEST_CASE() [7/15]

BOOST_AUTO_TEST_CASE

(

single_available_worker_executes_all_tasks

)

Definition at line 148 of file threadpool_tests.cpp.

Here is the call graph for this function:

BOOST_AUTO_TEST_CASE() [8/15]

BOOST_AUTO_TEST_CASE

(

start_mid_stop_does_not_deadlock

)

Definition at line 363 of file threadpool_tests.cpp.

Here is the call graph for this function:

BOOST_AUTO_TEST_CASE() [9/15]

BOOST_AUTO_TEST_CASE

(

stop_active_wait_drains_queue

)

Definition at line 421 of file threadpool_tests.cpp.

Here is the call graph for this function:

BOOST_AUTO_TEST_CASE() [10/15]

BOOST_AUTO_TEST_CASE

(

submit_fails_with_correct_error

)

Definition at line 81 of file threadpool_tests.cpp.

Here is the call graph for this function:

BOOST_AUTO_TEST_CASE() [11/15]

BOOST_AUTO_TEST_CASE

(

submit_range_of_tasks_complete_successfully

)

Definition at line 457 of file threadpool_tests.cpp.

Here is the call graph for this function:

BOOST_AUTO_TEST_CASE() [12/15]

BOOST_AUTO_TEST_CASE

(

submit_tasks_complete_successfully

)

Definition at line 123 of file threadpool_tests.cpp.

Here is the call graph for this function:

BOOST_AUTO_TEST_CASE() [13/15]

BOOST_AUTO_TEST_CASE

(

task_exception_propagates_to_future

)

Definition at line 201 of file threadpool_tests.cpp.

Here is the call graph for this function:

BOOST_AUTO_TEST_CASE() [14/15]

BOOST_AUTO_TEST_CASE

(

task_submitted_while_busy_completes

)

Definition at line 269 of file threadpool_tests.cpp.

Here is the call graph for this function:

BOOST_AUTO_TEST_CASE() [15/15]

BOOST_AUTO_TEST_CASE

(

wait_for_task_to_finish

)

Definition at line 174 of file threadpool_tests.cpp.

Here is the call graph for this function:

Submit()

template<typename F >

auto Submit	(	ThreadPool &	pool,
		F &&	fn
	)

Definition at line 60 of file threadpool_tests.cpp.

Here is the call graph for this function:

Here is the caller graph for this function:

Variable Documentation

NUM_WORKERS_DEFAULT

int NUM_WORKERS_DEFAULT = 0

Definition at line 22 of file threadpool_tests.cpp.

POOL_NAME

constexpr char POOL_NAME[] = "test"

constexpr

Definition at line 23 of file threadpool_tests.cpp.

TEST_WAIT_TIMEOUT

constexpr auto TEST_WAIT_TIMEOUT = 120s

constexpr

Definition at line 24 of file threadpool_tests.cpp.