71 lines
1.3 KiB
C
71 lines
1.3 KiB
C
#ifndef BH_INTERNAL_THREAD_H
|
|
#define BH_INTERNAL_THREAD_H
|
|
|
|
#include "bh.h"
|
|
#include <bh/thread.h>
|
|
#include "queue.h"
|
|
|
|
#define BH_THREAD_DONE 0x0100
|
|
|
|
#define BH_MAX_TLS 32
|
|
|
|
#if defined(BH_PLATFORM_POSIX) && defined(BH_PLATFORM_THREADS)
|
|
#include "thread_posix.h"
|
|
#elif defined(BH_PLATFORM_WIN) && defined(BH_PLATFORM_THREADS)
|
|
#include "thread_win.h"
|
|
#else
|
|
#include "thread_null.h"
|
|
#endif
|
|
|
|
struct bh_task_s
|
|
{
|
|
void (*func)(void *);
|
|
void *data;
|
|
int flags;
|
|
};
|
|
|
|
struct bh_thread_pool_s
|
|
{
|
|
bh_thread_t *threads;
|
|
bh_queue_t tasks;
|
|
bh_mutex_t lock;
|
|
bh_cond_t new_task;
|
|
bh_cond_t done_task;
|
|
size_t size;
|
|
size_t active;
|
|
int shutdown;
|
|
};
|
|
|
|
typedef struct bh_tls_info_s
|
|
{
|
|
size_t counter;
|
|
bh_spinlock_t lock;
|
|
bh_generic_cb_t cleanup[BH_MAX_TLS];
|
|
} bh_tls_info_t;
|
|
|
|
typedef struct bh_tls_s
|
|
{
|
|
void *data[BH_MAX_TLS];
|
|
} bh_tls_t;
|
|
|
|
void bh_task_init(bh_task_t *task,
|
|
void (*func)(void *),
|
|
void *data,
|
|
int flags);
|
|
|
|
void bh_task_destroy(bh_task_t *task);
|
|
|
|
void bh_thread_pool_worker(void *arg);
|
|
|
|
void bh_spinlock_init(bh_spinlock_t *lock);
|
|
|
|
void bh_spinlock_destroy(bh_spinlock_t *lock);
|
|
|
|
bh_tls_info_t *bh_tls_info(void);
|
|
|
|
bh_tls_t *bh_tls_fetch(void);
|
|
|
|
void bh_tls_cleanup(void);
|
|
|
|
#endif /* BH_INTERNAL_THREAD_H */
|