Verwendung von Threads und Warteschlange in VC++

Question

Ich möchte zwei Warteschlangen verwenden, wobei die erste Warteschlange die Daten in die Warteschlange verschiebt und der zweite Thread die Daten aus der Warteschlange entfernt. Kann mir jemand bei der Implementierung in VC++ helfen?

Ich bin neu in den Threads und der Warteschlange.

Answer 1

Dies ist der Erzeuger/Verbraucher-Problem, hier ist ein implementation davon in C++

Answer 2

Hier ein paar Hinweise und einige Codebeispiel:

std::queue<int> data; // the queue 
boost::mutex access; // a mutex for synchronising access to the queue 
boost::condition cond; // a condition variable for communicating the queue state 

bool empty() 
{ 
    return data.empty(); 
} 

void thread1() // the consumer thread 
{ 
    while (true) 
    { 
    boost::mutex::scoped_lock lock(access); 
    cond.wait(lock, empty); 
    while (!empty()) 
    { 
     int datum=data.top(); 
     data.pop(); 

     // do something with the data 
    } 
    } 
} 

void thread2() // the producer thread 
{ 
    while (true) 
    { 
    boost::mutex::scoped_lock lock(access); 
    data.push_back(1); // guaranteed random by a fair dice roll 
    cond.notify_one();   
    } 
} 

int main() 
{ 
    boost::thread t1(thread1); 
    boost::thread t2(thread2); 
    t1.join(); 
    t2.join(); 

    return 0; 
} 

ich eine queue vom STL verwendet und threads , condition variables und mutexes aus der Boost Bibliothek. Das Zeug in Boost ist so ziemlich das, was in der standard C++ library in a few yearsso it is good to be familiar with it sein wird.

Ich habe nur den Code eingegeben, ich habe keine Möglichkeit, es zu testen. Sie werden wahrscheinlich Fehler finden. Dies ist eine gute Sache, Threaded Code ist schwierig und der beste Weg, um es gut zu machen ist viel Übung.