Function ThreadPools_AddWorkWriter

src/util/thpool/pools.c:154–166

add task for writer thread

// add task for writer thread
int ThreadPools_AddWorkWriter
(
	void (*function_p)(void *),
	void *arg_p,
	int force
) {
	ASSERT(_writers_thpool != NULL);

	// make sure there's enough room in thread pool queue
	if(thpool_queue_full(_writers_thpool) && !force) return THPOOL_QUEUE_FULL;

	return thpool_add_work(_writers_thpool, function_p, arg_p);
}

void ThreadPools_SetMaxPendingWork(uint64_t val) {
	if(_readers_thpool != NULL) thpool_set_jobqueue_cap(_readers_thpool, val);