rt/mergerfs
1
0
Fork 0
mirror of https://github.com/trapexit/mergerfs.git synced 2026-10-26 19:01:56 -04:00
Code Issues Projects Releases Packages Wiki Activity Actions

Change threadpool to use concurrentqueue

Browse source
This commit is contained in:
Antonio SJ Musumeci 2023-08-30 14:43:58 -05:00
parent a927a15e9c
commit 76c8d48dbd
20 changed files with 9774 additions and 494 deletions
Download patch file Download diff file Expand all files Collapse all files

9
libfuse/lib/fuse_loop.cpp
View file

@ -5,6 +5,7 @@
#include "bounded_thread_pool.hpp"
#include "cpu.hpp"
#include "fmt/core.h"
#include "make_unique.hpp"
#include "scope_guard.hpp"
#include "syslog.h"
@ -87,6 +88,7 @@ struct AsyncWorker
DEFER{ fuse_session_exit(_se); };
DEFER{ sem_post(_finished); };
moodycamel::ProducerToken ptok(_process_tp->queue());
while(!fuse_session_exited(_se))
{
int rv;
@ -107,10 +109,13 @@ struct AsyncWorker
return handle_receive_error(rv,msgbuf);
} while(false);
_process_tp->enqueue_work([=] {
auto const func = [=]
{
_se->process_buf(_se,msgbuf);
msgbuf_free(msgbuf);
});
};
_process_tp->enqueue_work(ptok,func);
}
}
};