Commit 07fbff85 authored by neverlord's avatar neverlord

member reordering

parent 334b84d6
...@@ -24,11 +24,12 @@ struct network_manager_impl : network_manager ...@@ -24,11 +24,12 @@ struct network_manager_impl : network_manager
typedef util::single_reader_queue<mailman_job> mailman_queue_t; typedef util::single_reader_queue<mailman_job> mailman_queue_t;
int m_pipe[2]; // m_pipe[0]: read; m_pipe[1]: write int m_pipe[2]; // m_pipe[0]: read; m_pipe[1]: write
thread m_loop; // post office thread
mailman_queue_t m_mailman_queue; mailman_queue_t m_mailman_queue;
post_office_queue_t m_post_office_queue; post_office_queue_t m_post_office_queue;
thread m_loop; // post office thread
void start() /*override*/ void start() /*override*/
{ {
if (pipe(m_pipe) != 0) if (pipe(m_pipe) != 0)
......
...@@ -30,9 +30,9 @@ struct thread_pool_scheduler::worker ...@@ -30,9 +30,9 @@ struct thread_pool_scheduler::worker
job_queue* m_job_queue; job_queue* m_job_queue;
scheduled_actor* m_job; scheduled_actor* m_job;
worker_queue* m_supervisor_queue; worker_queue* m_supervisor_queue;
thread m_thread;
mutex m_mtx; mutex m_mtx;
condition_variable m_cv; condition_variable m_cv;
thread m_thread;
worker(worker_queue* supervisor_queue, job_queue* jq) worker(worker_queue* supervisor_queue, job_queue* jq)
: next(nullptr), m_done(false), m_job_queue(jq), m_job(nullptr) : next(nullptr), m_done(false), m_job_queue(jq), m_job(nullptr)
......
Markdown is supported
0%
or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment