gvsafronov/futriix
1
0
Fork 0
Code Issues Pull Requests Actions 3 Packages Projects Releases Wiki Activity

Threaded IO: use main thread if num of threads is 1.

Browse Source
This commit is contained in:
antirez 2019-03-27 18:39:13 +01:00
parent 9bf7f302a7
commit 30091dc29f
1 changed files with 11 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

13
src/networking.c
View File

@ -2525,11 +2525,16 @@ void *IOThreadMain(void *myid) {
/* Initialize the data structures needed for threaded I/O. */ /* Initialize the data structures needed for threaded I/O. */
void initThreadedIO(void) { void initThreadedIO(void) {
pthread_t tid;
server.io_threads_num = 8; server.io_threads_num = 8;
io_threads_active = 0; /* We start with threads not active. */ io_threads_active = 0; /* We start with threads not active. */
/* Don't spawn any thread if the user selected a single thread:
* we'll handle I/O directly from the main thread. */
if (server.io_threads_num == 1) return;
/* Spawn the I/O threads. */
for (int i = 0; i < server.io_threads_num; i++) { for (int i = 0; i < server.io_threads_num; i++) {
pthread_t tid;
pthread_mutex_init(&io_threads_mutex[i],NULL); pthread_mutex_init(&io_threads_mutex[i],NULL);
io_threads_pending[i] = 0; io_threads_pending[i] = 0;
io_threads_list[i] = listCreate(); io_threads_list[i] = listCreate();
@ -2569,6 +2574,10 @@ void stopThreadedIO(void) {
* could be possibly stopped (if already active) as a side effect. */ * could be possibly stopped (if already active) as a side effect. */
int stopThreadedIOIfNeeded(void) { int stopThreadedIOIfNeeded(void) {
int pending = listLength(server.clients_pending_write); int pending = listLength(server.clients_pending_write);
/* Return ASAP if IO threads are disabled (single threaded mode). */
if (server.io_threads_num == 1) return 0;
if (pending < (server.io_threads_num*2)) { if (pending < (server.io_threads_num*2)) {
if (io_threads_active) stopThreadedIO(); if (io_threads_active) stopThreadedIO();
return 1; return 1;