Boost Interthread Communication

Question

Мне нужно внедрить ускоренную межпоточную связь. Рассмотрим следующий код:

#include <boost/thread/thread.hpp> 
#include <Windows.h> 
void threadA() 
{ 
    while(true) 
    { 
     std::cout << "From thread A" << std::endl; 
     Sleep(3000); //pretend to do the work 
    } 
} 

void threadB() 
{ 
    while(true) 
    { 
     std::cout << "From thread B" << std::endl; 
     Sleep(3000); //pretend to do the work 
    } 
} 

int main() 
{ 
    boost::thread *th1 = new boost::thread(&threadA); 
    boost::thread *th2 = new boost::thread(&threadB); 
    th1->join(); 
    th2->join(); 
    delete th1; 
    delete th2; 
} 

Если я запустил вышеуказанный код, он будет порождать оба потока. То, что я хочу сделать, это запустить threadA и отправить сообщение threadB, которое после получения начнет тему. Или больше Как правило, как я могу обрабатывать связь, если оба эти потока работают независимо?

Answer 1

Существует много способов.

• использование переменного условия (ака. Событие)
• использовать параллельную очередь (сообщения, например) или в более общем плане, семафоры
• использования lockfree структуры параллельных данные

подталкивания обеспечивает реализацию все вышеперечисленное.