Suspend-und resume-ein C++ thread in einem anderen

Ich habe eine C++ - code mit zwei threads in es. Nach einem Ereignis " A " in thread 2, thread 1 sein sollte angehalten(suspended), einige weitere Aufgaben ausgeführt werden sollen, in thread 2 (sagen wir Fall 'B')und schließlich-thread 1 wieder aufgenommen werden sollen. Gibt es eine Möglichkeit, dies zu tun?

Mein code sieht ungefähr so aus:

HANDLE C;
DWORD WINAPI A (LPVOID in)
{
    while(1){
        //some operation
    }
    return 0;
}

DWORD WINAPI B (LPVOID in)
{
    while(1){

        //Event A occurs here

        SuspendThread (C);

        //Event B occurs here

        ResumeThread (C);
        }
    return 0;
}

int main()
{
    C = CreateThread (NULL, 0, A, NULL, 0, NULL);
    CreateThread (NULL, 0, B, NULL, 0, NULL);
    return 0;
}
  • Sie tun jetzt, was das problem ist?
  • Random deadlock, kein Zweifel.
InformationsquelleAutor Vigo | 2013-03-19
  1. 10

    Hallo ich habe ein Beispiel, das ich habe, inspiriert von cpp-Referenz.
    Das Beispiel verwendet C++ 11 so gegeben, daß diese Frage nicht gekennzeichnet win32-aber c++ und multithreading, poste ich etwas.

    Erste hier ist der original link.

    http://en.cppreference.com/w/cpp/thread/sleep_for

    Nun, hier ist der code, den ich bekam, der das problem löst.

    #include <iostream>
#include <string>
#include <thread>
#include <mutex>
#include <condition_variable>

std::mutex m;
std::condition_variable cv;
std::string data;
bool ready = false;
bool processed = false;

void ThreadB_Activity()
{
    //Wait until ThreadA() sends data
    {
        std::unique_lock<std::mutex> lk(m);
        cv.wait(lk, []{return ready;});
    }

    std::cout << "Thread B is processing data\n";
    data += " after processing";
    //Send data back to ThreadA through the condition variable
    {
        std::lock_guard<std::mutex> lk(m);
        processed = true;
        std::cout << "Thread B signals data processing completed\n";
    }
    cv.notify_one();
}


void ThreadA_Activity()
{
    std::cout<<"Thread A started "<<std::endl;
    data = "Example data";
    //send data to the worker thread
    {
        std::lock_guard<std::mutex> lk(m);
        ready = true;
        std::cout << "Thread A signals data are ready to be processed\n";
    }
    cv.notify_one();//notify to ThreadB that he can start doing his job

    //wait for the Thread B
    {
        std::unique_lock<std::mutex> lk(m);
        cv.wait(lk, []{return processed;});
    }
    std::cout << "Back in Thread A , data = " << data << '\n';

    std::this_thread::sleep_for( std::chrono::milliseconds( 1000 ));
    std::cout<<"end of Thread A"<<std::endl;
}


int main()
{
    std::thread ThreadB(ThreadB_Activity);
    std::thread ThreadA(ThreadA_Activity);

    ThreadB.join();
    ThreadA.join();

    std::cout << "Back in main , data = " << data << '\n';
    return 0;
}

    Hoffe, das hilft, alle Kommentare sind willkommen 🙂

    InformationsquelleAutor Gabriel
  2. 0

    Da Sie zu sein scheinen mit win32 können Sie eine event

    Wenn Sie wollen, etwas zu tun, ähnlich wie in pthreads-es ist ein Beispiel hier.

    In beiden Fällen, den Faden zu testen, wird ein Bedingungs/Ereignis - (und warten, ob es eingestellt wird oder weiter, wenn es nicht ist) und der thread B wird gesetzt und klar die Bedingung/Ereignis. Hinweis: Sie müssen möglicherweise auch eine mutex zwischen thread A und B je nachdem, was Sie tun, können Sie korrupte jeder andere?

    InformationsquelleAutor iain
Schreibe einen Kommentar