Class cubthread::manager¶

ClassList > cubthread > manager

#include <thread_manager.hpp>

Public Types¶

Type	Name
typedef cubbase::count_registry< connection >	connection_registry_t
typedef cubbase::count_registry< daemon >	daemon_registry_t
typedef cubbase::count_registry< worker_pool >	workerpool_registry_t

Public Functions¶

Type	Name
void	alloc_entries (void)
void	check_all_killed (void)
entry *	claim_entry (void)
void	clear_all_holder_anchor (void)
daemon *	create_daemon (const looper & looper_arg, entry_task * exec_p, const char * daemon_name="", entry_manager * entry_mgr=NULL)
daemon *	create_daemon_without_entry (const looper & looper_arg, task_without_context * exec_p, const char * daemon_name)
Res *	create_worker_pool (std::size_t pool_size, std::size_t core_count, CtArgs &&... args)
void	destroy_daemon (daemon *& daemon_arg)
void	destroy_daemon_without_entry (daemon *& daemon_arg)
void	destroy_worker_pool (Res *& worker_pool_arg)
entry *	find_by_tid (thread_id_t tid)
entry *	get_all_entries (void)
entry_manager &	get_entry_manager (void)
lockfree::tran::system &	get_lockfree_transys ()
std::size_t	get_max_thread_count (void) const
void	init_entries (bool with_lock_free=false)
void	init_lockfree_system ()
	manager ()
void	map_entries (Func && func, Args &&... args)
void	push_task (worker_pool * worker_pool_arg, entry_task * exec_p)
void	push_task_on_core (worker_pool * worker_pool_arg, entry_task * exec_p, std::size_t core_hash, bool method_mode)
void	retire_entry (entry & entry_p)
void	return_lock_free_transaction_entries (void)
void	set_max_thread_count (std::size_t count)
void	set_max_thread_count_from_config ()
	~manager ()

Public Types Documentation¶

typedef connection_registry_t¶

using cubthread::manager::connection_registry_t =  cubbase::count_registry<connection>;

typedef daemon_registry_t¶

using cubthread::manager::daemon_registry_t =  cubbase::count_registry<daemon>;

typedef workerpool_registry_t¶

using cubthread::manager::workerpool_registry_t =  cubbase::count_registry<worker_pool>;

Public Functions Documentation¶

function alloc_entries¶

void cubthread::manager::alloc_entries (
    void
)

function check_all_killed¶

void cubthread::manager::check_all_killed (
    void
)

function claim_entry¶

entry * cubthread::manager::claim_entry (
    void
)

function clear_all_holder_anchor¶

inline void cubthread::manager::clear_all_holder_anchor (
    void
)

function create_daemon¶

daemon * cubthread::manager::create_daemon (
    const  looper & looper_arg,
    entry_task * exec_p,
    const  char * daemon_name="",
    entry_manager * entry_mgr=NULL
)

function create_daemon_without_entry¶

daemon * cubthread::manager::create_daemon_without_entry (
    const  looper & looper_arg,
    task_without_context * exec_p,
    const  char * daemon_name
)

function create_worker_pool¶

template<typename  Res, typename ... CtArgs>
Res * cubthread::manager::create_worker_pool (
    std::size_t pool_size,
    std::size_t core_count,
    CtArgs &&... args
)

function destroy_daemon¶

void cubthread::manager::destroy_daemon (
    daemon *& daemon_arg
)

function destroy_daemon_without_entry¶

void cubthread::manager::destroy_daemon_without_entry (
    daemon *& daemon_arg
)

function destroy_worker_pool¶

template<typename  Res>
void cubthread::manager::destroy_worker_pool (
    Res *& worker_pool_arg
)

function find_by_tid¶

entry * cubthread::manager::find_by_tid (
    thread_id_t tid
)

function get_all_entries¶

inline entry * cubthread::manager::get_all_entries (
    void
)

function get_entry_manager¶

inline entry_manager & cubthread::manager::get_entry_manager (
    void
)

function get_lockfree_transys¶

inline lockfree::tran::system & cubthread::manager::get_lockfree_transys ()

function get_max_thread_count¶

std::size_t cubthread::manager::get_max_thread_count (
    void
) const

function init_entries¶

void cubthread::manager::init_entries (
    bool with_lock_free=false
)

function init_lockfree_system¶

void cubthread::manager::init_lockfree_system ()

function manager¶

cubthread::manager::manager ()

function map_entries¶

template<typename  Func, typename ... Args>
void cubthread::manager::map_entries (
    Func && func,
    Args &&... args
)

function push_task¶

void cubthread::manager::push_task (
    worker_pool * worker_pool_arg,
    entry_task * exec_p
)

function push_task_on_core¶

void cubthread::manager::push_task_on_core (
    worker_pool * worker_pool_arg,
    entry_task * exec_p,
    std::size_t core_hash,
    bool method_mode
)

function retire_entry¶

void cubthread::manager::retire_entry (
    entry & entry_p
)

function return_lock_free_transaction_entries¶

void cubthread::manager::return_lock_free_transaction_entries (
    void
)

function set_max_thread_count¶

void cubthread::manager::set_max_thread_count (
    std::size_t count
)

function set_max_thread_count_from_config¶

void cubthread::manager::set_max_thread_count_from_config ()

function ~manager¶

cubthread::manager::~manager ()

The documentation for this class was generated from the following file cubrid/src/thread/thread_manager.hpp