Function ThreadPools_CreatePools

src/util/thpool/pools.c:41–59

set up thread pools (readers and writers) returns 1 if thread pools initialized, 0 otherwise

// set up thread pools  (readers and writers)
// returns 1 if thread pools initialized, 0 otherwise
int ThreadPools_CreatePools
(
	uint reader_count,
	uint writer_count,
	uint64_t max_pending_work
) {
	ASSERT(_readers_thpool == NULL);
	ASSERT(_writers_thpool == NULL);

	_readers_thpool = thpool_init(reader_count, "reader");
	if(_readers_thpool == NULL) return 0;

	_writers_thpool = thpool_init(writer_count, "writer");
	if(_writers_thpool == NULL) return 0;

	ThreadPools_SetMaxPendingWork(max_pending_work);

	return 1;
}

// return number of threads in both the readers and writers pools
uint ThreadPools_ThreadCount