小編給大家分享一下Ceph網絡層代碼之線程的示例分析，相信大部分人都還不怎么了解，因此分享這篇文章給大家參考一下，希望大家閱讀完這篇文章后大有收獲，下面讓我們一起去了解一下吧！
Pipe寫線程是從哪里開始啟動的?
Pipe *SimpleMessenger::connect_rank() ---->pipe->start_writer(); //啟動Writer線程
Pipe讀線程是從哪里開始啟動的?
void SimpleMessenger::ready()
----> accepter.start();
Pipe *SimpleMessenger::add_accept_pipe(int sd)
{
p->start_reader();
p->pipe_lock.Unlock();
pipes.insert(p);
accepting_pipes.insert(p);
lock.Unlock();
return p;
}
void Pipe::start_reader()
{
assert(pipe_lock.is_locked());
assert(!reader_running);
if (reader_needs_join) {
reader_thread.join();
reader_needs_join = false;
}
reader_running = true;
reader_thread.create(msgr->cct->_conf->ms_rwthread_stack_bytes);
}
void Pipe::reader() //啟動reader線程.DispatcherQueue線程是從哪里開始啟動的?
void SimpleMessenger::ready()
{
ldout(cct,10) << "ready " << get_myaddr() << dendl;
dispatch_queue.start();
lock.Lock();
if (did_bind)
accepter.start();
lock.Unlock();
}以上是“Ceph網絡層代碼之線程的示例分析”這篇文章的所有內容，感謝各位的閱讀！相信大家都有了一定的了解，希望分享的內容對大家有所幫助，如果還想學習更多知識，歡迎關注億速云行業資訊頻道！
免責聲明：本站發布的內容（圖片、視頻和文字）以原創、轉載和分享為主，文章觀點不代表本網站立場，如果涉及侵權請聯系站長郵箱：is@yisu.com進行舉報，并提供相關證據，一經查實，將立刻刪除涉嫌侵權內容。
