File thread_manager.hpp¶

FileList > cubrid > src > thread > thread_manager.hpp

#include "thread_entry.hpp"
#include "thread_entry_task.hpp"
#include "thread_task.hpp"
#include "thread_waiter.hpp"
#include "thread_worker_pool_impl.hpp"
#include "count_registry.hpp"
#include "base_flag.hpp"
#include <mutex>
#include <vector>

Namespaces¶

Type	Name
namespace	cubthread
namespace	lockfree
namespace	tran

Classes¶

Type	Name
class	manager

Public Functions¶

Type	Name
void	thread_clear_all_holder_anchor (void)
cubthread::stats_worker_pool_type *	thread_create_stats_worker_pool (std::size_t pool_size, std::size_t core_count, const char * name, cubthread::entry_manager & entry_mgr, bool pool_threads=false, cubthread::wait_seconds idle_timeout=std::chrono::seconds(5))
cubthread::worker_pool_type *	thread_create_worker_pool (std::size_t pool_size, std::size_t core_count, const char * name, cubthread::entry_manager & entry_mgr, bool pool_threads=false)
int	thread_get_current_entry_index (void)
int	thread_get_entry_index (cubthread::entry * thread_p)
cubthread::entry_manager &	thread_get_entry_manager (void)
cubthread::manager *	thread_get_manager (void)
cubthread::entry *	thread_get_thread_entry_info (void)
lf_tran_entry *	thread_get_tran_entry (cubthread::entry * thread_p, int entry_idx)
std::size_t	thread_num_total_threads (void)
void	thread_return_lock_free_transaction_entries (void)
void	thread_sleep (double millisec)
void	thread_sleep_for (Duration d)

Macros¶

Type	Name
define	REGISTER_CONNECTION (name, getter) `[static](broker__monitor_8c.md#function-timeout) [cubthread::manager::connection\_registry\_t](classcubthread_1_1manager.md#typedef-connection_registry_t) [\_gl\_reg\_conn\_](broker__monitor_8c.md#function-timeout)##name (#name, [getter](broker__monitor_8c.md#function-timeout))`
define	REGISTER_DAEMON (name) `[static](broker__monitor_8c.md#function-timeout) [cubthread::manager::daemon\_registry\_t](classcubthread_1_1manager.md#typedef-daemon_registry_t) [\_gl\_reg\_daemon\_](broker__monitor_8c.md#function-timeout)##name (#name, 1)`
define	REGISTER_WORKERPOOL (name, getter) `[static](broker__monitor_8c.md#function-timeout) [cubthread::manager::workerpool\_registry\_t](classcubthread_1_1manager.md#typedef-workerpool_registry_t) [\_gl\_reg\_wp\_](broker__monitor_8c.md#function-timeout)##name (#name, [getter](broker__monitor_8c.md#function-timeout))`

Public Functions Documentation¶

function thread_clear_all_holder_anchor¶

inline void thread_clear_all_holder_anchor (
    void
)

function thread_create_stats_worker_pool¶

inline cubthread::stats_worker_pool_type * thread_create_stats_worker_pool (
    std::size_t pool_size,
    std::size_t core_count,
    const  char * name,
    cubthread::entry_manager & entry_mgr,
    bool pool_threads=false,
    cubthread::wait_seconds idle_timeout=std::chrono::seconds (5)
)

function thread_create_worker_pool¶

inline cubthread::worker_pool_type * thread_create_worker_pool (
    std::size_t pool_size,
    std::size_t core_count,
    const  char * name,
    cubthread::entry_manager & entry_mgr,
    bool pool_threads=false
)

function thread_get_current_entry_index¶

inline int thread_get_current_entry_index (
    void
)

function thread_get_entry_index¶

inline int thread_get_entry_index (
    cubthread::entry * thread_p
)

function thread_get_entry_manager¶

inline cubthread::entry_manager & thread_get_entry_manager (
    void
)

function thread_get_manager¶

inline cubthread::manager * thread_get_manager (
    void
)

function thread_get_thread_entry_info¶

inline cubthread::entry * thread_get_thread_entry_info (
    void
)

function thread_get_tran_entry¶

inline lf_tran_entry * thread_get_tran_entry (
    cubthread::entry * thread_p,
    int entry_idx
)

function thread_num_total_threads¶

inline std::size_t thread_num_total_threads (
    void
)

function thread_return_lock_free_transaction_entries¶

inline void thread_return_lock_free_transaction_entries (
    void
)

function thread_sleep¶

inline void thread_sleep (
    double millisec
)

function thread_sleep_for¶

template<typename  Duration>
inline void thread_sleep_for (
    Duration d
)

Macro Definition Documentation¶

define REGISTER_CONNECTION¶

#define REGISTER_CONNECTION (
    name,
    getter
) `static  cubthread::manager::connection_registry_t  _gl_reg_conn_ ##name (#name, getter )`

define REGISTER_DAEMON¶

#define REGISTER_DAEMON (
    name
) `static  cubthread::manager::daemon_registry_t  _gl_reg_daemon_ ##name (#name, 1)`

define REGISTER_WORKERPOOL¶

#define REGISTER_WORKERPOOL (
    name,
    getter
) `static  cubthread::manager::workerpool_registry_t  _gl_reg_wp_ ##name (#name, getter )`

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