Thread pool adapter for async database operations. More...

#include <thread_adapter.h>

Collaboration diagram for database::integrated::adapters::thread_adapter:

Public Member Functions
	thread_adapter (const db_thread_config &config, thread_backend_type backend_type=thread_backend_type::auto_select)
	Construct thread adapter with configuration.

	~thread_adapter ()
	Destructor - ensures graceful shutdown.

	thread_adapter (const thread_adapter &)=delete

thread_adapter &	operator= (const thread_adapter &)=delete

	thread_adapter (thread_adapter &&) noexcept

thread_adapter &	operator= (thread_adapter &&)=delete

common::VoidResult	initialize ()
	Initialize thread pool.

common::VoidResult	shutdown ()
	Shutdown thread pool gracefully.

bool	is_initialized () const
	Check if thread pool is initialized.

common::VoidResult	execute (std::function< void()> task)
	Execute a task (fire-and-forget)

template<typename F , typename... Args> requires concepts::SubmittableTask<F, Args...>
auto	submit (F &&f, Args &&... args) -> std::future< std::invoke_result_t< F, Args... > >
	Submit a task and get a future.

void	wait_for_completion ()
	Wait for all pending tasks to complete.

bool	wait_for_completion_timeout (std::chrono::milliseconds timeout)
	Wait for tasks with timeout.

std::size_t	worker_count () const
	Get number of worker threads.

std::size_t	queue_size () const
	Get current queue size.

bool	is_idle () const
	Check if thread pool is idle.

Static Private Member Functions
static std::unique_ptr< backends::thread_backend >	create_backend (const db_thread_config &config, thread_backend_type backend_type)
	Create appropriate backend based on type.

Private Attributes
const db_thread_config &	config_

std::unique_ptr< backends::thread_backend >	backend_
	Thread backend implementation.

Detailed Description

Thread pool adapter for async database operations.

Provides unified async execution with runtime backend selection. No longer uses conditional compilation - backend is selected at runtime.

Thread Safety: All methods are thread-safe Exception Safety: Strong guarantee - failed operations don't affect pool state

Examples: /home/runner/work/database_system/database_system/database/integrated/core/database_coordinator.h.

Definition at line 98 of file thread_adapter.h.

Constructor & Destructor Documentation

◆ thread_adapter() [1/3]

database::integrated::adapters::thread_adapter::thread_adapter	(	const db_thread_config &	config,
		thread_backend_type	backend_type = thread_backend_type::auto_select )

explicit

Construct thread adapter with configuration.

Parameters

config	Thread pool configuration
backend_type	Backend type to use (default: auto_select)

Examples: /home/runner/work/database_system/database_system/database/integrated/adapters/thread_adapter.h.

Definition at line 43 of file thread_adapter.cpp.

    : config_(config)
    , backend_(create_backend(config, backend_type))
{
}

◆ ~thread_adapter()

database::integrated::adapters::thread_adapter::~thread_adapter ( )

Destructor - ensures graceful shutdown.

Examples: /home/runner/work/database_system/database_system/database/integrated/adapters/thread_adapter.h.

Definition at line 51 of file thread_adapter.cpp.

{
    if (backend_ && backend_->is_initialized())
    {
        backend_->shutdown();
    }
}

References backend_.

◆ thread_adapter() [2/3]

database::integrated::adapters::thread_adapter::thread_adapter ( const thread_adapter & )

delete

◆ thread_adapter() [3/3]

database::integrated::adapters::thread_adapter::thread_adapter ( thread_adapter && )

defaultnoexcept

Member Function Documentation

◆ create_backend()

std::unique_ptr< backends::thread_backend > database::integrated::adapters::thread_adapter::create_backend	(	const db_thread_config &	config,
		thread_backend_type	backend_type )

staticprivate

Create appropriate backend based on type.

Examples: /home/runner/work/database_system/database_system/database/integrated/adapters/thread_adapter.h.

Definition at line 21 of file thread_adapter.cpp.

{
    switch (backend_type)
    {
        case thread_backend_type::auto_select:
        case thread_backend_type::fallback:
            return std::make_unique<backends::fallback_thread_backend>(config);
 
        case thread_backend_type::null:
            return std::make_unique<backends::null_thread_backend>(config);
 
        default:
            return std::make_unique<backends::fallback_thread_backend>(config);
    }
}

References database::integrated::adapters::auto_select, database::integrated::adapters::fallback, and database::integrated::adapters::null.

◆ execute()

common::VoidResult database::integrated::adapters::thread_adapter::execute ( std::function< void()> task )

Execute a task (fire-and-forget)

Parameters

task	Task to execute

Returns: Ok on successful submission

Examples: /home/runner/work/database_system/database_system/database/integrated/adapters/thread_adapter.h.

Definition at line 91 of file thread_adapter.cpp.

{
    if (!backend_)
    {
        return common::VoidResult(
            common::error_info{ -1, "Backend not initialized", "" });
    }
 
    return backend_->execute(std::move(task));
}

References backend_.

Referenced by submit().

Here is the caller graph for this function:

◆ initialize()

common::VoidResult database::integrated::adapters::thread_adapter::initialize ( )

Initialize thread pool.

Returns: Ok on success, error otherwise

Examples: /home/runner/work/database_system/database_system/database/integrated/adapters/thread_adapter.h.

Definition at line 61 of file thread_adapter.cpp.

{
    if (!backend_)
    {
        return common::VoidResult(
            common::error_info{ -1, "Backend not created", "" });
    }
 
    return backend_->initialize();
}

References initialize().

Referenced by initialize(), test_api_availability_priority(), test_api_availability_submit(), test_destructor_safety(), test_double_initialization(), and test_move_semantics().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ is_idle()

bool database::integrated::adapters::thread_adapter::is_idle ( ) const

Check if thread pool is idle.

Returns: true if no tasks are running or pending

Examples: /home/runner/work/database_system/database_system/database/integrated/adapters/thread_adapter.h.

Definition at line 148 of file thread_adapter.cpp.

{
    if (!backend_)
    {
        return true;
    }
 
    return backend_->is_idle();
}

References backend_.

◆ is_initialized()

bool database::integrated::adapters::thread_adapter::is_initialized ( ) const

Check if thread pool is initialized.

Returns: true if initialized and ready to accept tasks

Examples: /home/runner/work/database_system/database_system/database/integrated/adapters/thread_adapter.h.

Definition at line 82 of file thread_adapter.cpp.

{
    return backend_ && backend_->is_initialized();
}

References backend_.

◆ operator=() [1/2]

thread_adapter & database::integrated::adapters::thread_adapter::operator= ( const thread_adapter & )

delete

Examples: /home/runner/work/database_system/database_system/database/integrated/adapters/thread_adapter.h.

◆ operator=() [2/2]

thread_adapter & database::integrated::adapters::thread_adapter::operator= ( thread_adapter && )

delete

◆ queue_size()

std::size_t database::integrated::adapters::thread_adapter::queue_size ( ) const

Get current queue size.

Returns: Number of pending tasks

Examples: /home/runner/work/database_system/database_system/database/integrated/adapters/thread_adapter.h.

Definition at line 138 of file thread_adapter.cpp.

{
    if (!backend_)
    {
        return 0;
    }
 
    return backend_->queue_size();
}

References backend_.

Referenced by test_api_availability_stats().

Here is the caller graph for this function:

◆ shutdown()

common::VoidResult database::integrated::adapters::thread_adapter::shutdown ( )

Shutdown thread pool gracefully.

Waits for all pending tasks to complete before shutting down. After shutdown, no new tasks can be submitted.

Returns: Ok on success

Examples: /home/runner/work/database_system/database_system/database/integrated/adapters/thread_adapter.h.

Definition at line 72 of file thread_adapter.cpp.

{
    if (!backend_)
    {
        return common::ok();
    }
 
    return backend_->shutdown();
}

References backend_, and common::ok().

Referenced by test_api_availability_priority(), test_api_availability_submit(), test_double_initialization(), test_move_semantics(), and test_shutdown_without_init().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ submit()

template<typename F , typename... Args>
requires concepts::SubmittableTask<F, Args...>

auto database::integrated::adapters::thread_adapter::submit	(	F &&	f,
		Args &&...	args ) -> std::future<std::invoke_result_t<F, Args...>>

Submit a task and get a future.

Template Parameters

F	Function type - constrained by SubmittableTask concept
Args	Argument types

Parameters

f	Function to execute
args	Arguments to pass to function

Returns: Future containing the result

Uses SubmittableTask concept for compile-time validation:

Ensures F is invocable with Args...
Ensures F is move-constructible for async storage

Examples: /home/runner/work/database_system/database_system/database/integrated/adapters/thread_adapter.h.

Definition at line 227 of file thread_adapter.h.

{
    using return_type = std::invoke_result_t<F, Args...>;
 
    auto task = std::make_shared<std::packaged_task<return_type()>>(
        std::bind(std::forward<F>(f), std::forward<Args>(args)...));
 
    auto result = task->get_future();
 
    execute([task = std::move(task)]() { (*task)(); });
 
    return result;
}

References execute().

Referenced by test_api_availability_priority(), test_api_availability_submit(), and test_destructor_safety().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ wait_for_completion()

void database::integrated::adapters::thread_adapter::wait_for_completion ( )

Wait for all pending tasks to complete.

Blocks until all submitted tasks finish execution.

Examples: /home/runner/work/database_system/database_system/database/integrated/adapters/thread_adapter.h.

Definition at line 106 of file thread_adapter.cpp.

{
    if (backend_)
    {
        backend_->wait_for_completion();
    }
}

References backend_.

◆ wait_for_completion_timeout()

bool database::integrated::adapters::thread_adapter::wait_for_completion_timeout ( std::chrono::milliseconds timeout )

Wait for tasks with timeout.

Parameters

timeout Maximum time to wait

Returns: true if all tasks completed, false if timeout

Examples: /home/runner/work/database_system/database_system/database/integrated/adapters/thread_adapter.h.

Definition at line 114 of file thread_adapter.cpp.

{
    if (!backend_)
    {
        return true;
    }
 
    return backend_->wait_for_completion_timeout(timeout);
}

References backend_, and database::timeout.

◆ worker_count()

std::size_t database::integrated::adapters::thread_adapter::worker_count ( ) const

Get number of worker threads.

Returns: Thread count

Examples: /home/runner/work/database_system/database_system/database/integrated/adapters/thread_adapter.h.

Definition at line 128 of file thread_adapter.cpp.

{
    if (!backend_)
    {
        return 0;
    }
 
    return backend_->worker_count();
}

References backend_.

Referenced by test_api_availability_stats().

Here is the caller graph for this function:

Member Data Documentation

◆ backend_

std::unique_ptr<backends::thread_backend> database::integrated::adapters::thread_adapter::backend_

private

Thread backend implementation.

Examples: /home/runner/work/database_system/database_system/database/integrated/adapters/thread_adapter.h.

Definition at line 218 of file thread_adapter.h.

Referenced by execute(), is_idle(), is_initialized(), queue_size(), shutdown(), wait_for_completion(), wait_for_completion_timeout(), worker_count(), and ~thread_adapter().

◆ config_

const db_thread_config& database::integrated::adapters::thread_adapter::config_

private

Examples: /home/runner/work/database_system/database_system/database/integrated/adapters/thread_adapter.h.

Definition at line 217 of file thread_adapter.h.

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

database/integrated/adapters/thread_adapter.h
database/integrated/adapters/thread_adapter.cpp

Public Member Functions

Static Private Member Functions

Private Attributes

Detailed Description

Constructor & Destructor Documentation

◆ thread_adapter() [1/3]

◆ ~thread_adapter()

◆ thread_adapter() [2/3]

◆ thread_adapter() [3/3]

Member Function Documentation

◆ create_backend()

◆ execute()

◆ initialize()

◆ is_idle()

◆ is_initialized()

◆ operator=() [1/2]

◆ operator=() [2/2]

◆ queue_size()

◆ shutdown()

◆ submit()

◆ wait_for_completion()

◆ wait_for_completion_timeout()

◆ worker_count()

Member Data Documentation

◆ backend_

◆ config_