1624 |
1624 |
1625 // threadpool |
1625 // threadpool |
1626 threadpool_t* threadpool_new(int min, int max); |
1626 threadpool_t* threadpool_new(int min, int max); |
1627 int threadpool_start(threadpool_t *pool); |
1627 int threadpool_start(threadpool_t *pool); |
1628 void* threadpool_func(void *data); |
1628 void* threadpool_func(void *data); |
1629 threadpool_job* threadpool_get_job(threadpool_t *pool); |
1629 threadpool_job* threadpool_get_job(threadpool_t *pool, int thread_index); |
1630 void threadpool_run(threadpool_t *pool, job_callback_f func, void *data); |
1630 void threadpool_run(threadpool_t *pool, job_callback_f func, void *data); |
1631 |
1631 |
1632 int event_pollin(EventHandler *ev, SYS_NETFD fd, Event *event); |
1632 int event_pollin(EventHandler *ev, SYS_NETFD fd, Event *event); |
1633 int event_pollout(EventHandler *ev, SYS_NETFD fd, Event *event); |
1633 int event_pollout(EventHandler *ev, SYS_NETFD fd, Event *event); |
1634 int event_removepoll(EventHandler *ev, SYS_NETFD fd); |
1634 int event_removepoll(EventHandler *ev, SYS_NETFD fd); |