Jak mogę rzetelnie stwierdzić, czy wątek boost zakończył działanie?

Question

Zakładam, że łączenie to wskazywałoby, jednak nie wydaje się, żeby tak było.

W klasie pracowników, starałem się wskazywać, że to wciąż przetwarzanie przez orzecznika:

bool isRunning(){return thread_->joinable();} 

Czy nie wątku, który odszedł nie być PŁYCIE? Czego mi brakuje ... Jakie jest znaczenie wątku boost :: joinable?

Answer 1

Ponieważ można dołączyć do wątku, nawet po jego zakończeniu, joinable() będzie nadal zwracać wartość true, dopóki nie wywołasz join() lub odłącz(). Jeśli chcesz się dowiedzieć, czy wątek nadal działa, powinieneś móc wywołać funkcję timed_join z czasem oczekiwania równym 0. Zauważ, że może to spowodować stan wyścigu, ponieważ wątek może zakończyć się tuż po zakończeniu połączenia.

Answer 2

Zasadniczo nie możesz tego zrobić. Powodem jest to, że dwiema możliwymi odpowiedziami są "Tak" i "Nie, kiedy ostatnio wyglądałem, ale może teraz". Nie ma niezawodnego sposobu na stwierdzenie, że wątek nadal znajduje się w jego metodzie run, nawet jeśli istnieje niezawodny sposób określenia czegoś przeciwnego.

Answer 3

Użyj thread::timed_join() z minimalnym limitem czasu. Zwróci wartość false, jeśli wątek nadal działa.

Answer 4

Używam doładowania 1.54, dzięki któremu etap timed_join() jest przestarzały. W zależności od użytkowania, można użyć PŁYCIE(), która działa idealnie do moich celów, lub alternatywnie można użyć try_join_for() lub try_join_until(), patrz:

http://www.boost.org/doc/libs/1_54_0/doc/html/thread/thread_management.html

Answer 5

Jest to nieco surowy, ale już teraz nadal działa zgodnie z moimi wymaganiami. :) Używam boost 153 i qt. Stworzyłem wektor int do śledzenia "statusu" moich wątków. Za każdym razem, gdy utworzę nowy wątek, dodaję jeden wpis do wątku thread_ids z wartością 0. Dla każdego utworzonego wątku przekazuję identyfikator, dzięki czemu wiem, jaką część wątków thread_ids mam aktualizować. Ustaw status na 1 dla bieżących i innych wartości w zależności od aktualnie wykonywanej aktywności, więc wiem, jakie czynności zostały wykonane po zakończeniu wątku. 100 to wartość ustawiona dla poprawnie ukończonego wątku. Nie jestem pewien, czy to pomoże, ale jeśli masz inne sugestie, jak to poprawić, daj mi znać. :)

std::vector<int> thread_ids; 
const int max_threads = 4; 
void Thread01(int n, int n2) 
{ 
    thread_ids.at(n) = 1; 
    boost::this_thread::sleep(boost::posix_time::milliseconds(n2 * 1000)); 
    thread_ids.at(n) = 100; 
    qDebug()<<"Done "<<n; 

} 
void getThreadsStatus() 
{ 
    qDebug()<<"status:"; 
    for(int i = 0; i < max_threads, i < thread_ids.size(); i++) 
    { 
     qDebug()<<thread_ids.at(i); 
    } 
} 
int main(int argc, char *argv[]) 
{ 
    for(int i = 0; i < max_threads; i++) 
    { 
     thread_ids.push_back(0); 
     threadpool.create_thread(
      boost::bind(&boost::asio::io_service::run, &ioService)); 
     ioService.post(boost::bind(Thread01, i, i + 2)); 
     getThreadsStatus(); 
    } 

    ioService.stop(); 
    threadpool.join_all(); 
    getThreadsStatus(); 
} 

Answer 6

Najprostszym sposobem, jeśli funkcja, która uruchamia twój wątek jest wystarczająco prosta, jest ustawienie zmiennej na wartość true, gdy funkcja jest zakończona. Oczywiście, potrzebujesz zmiennej na wątek, jeśli masz wiele map z identyfikatorami wątków, a stan może być lepszym rozwiązaniem. Wiem, że jest ręcznie, ale w międzyczasie działa dobrze.

class ThreadCreator 
{ 
private: 
    bool   m_threadFinished; 
    void launchProducerThread(){ 
     // do stuff here 
     m_threadRunning = true; 
    } 
public: 
    ThreadCreator() : m_threadFinished(false) { 
     boost::thread(&Consumer::launchProducerThread, this); 
    } 
}; 

Answer 7

To nie może być bezpośrednią odpowiedź na Twoje pytanie, ale widzę pojęcie wątku jako mechanizm bardzo lekkiego i celowo pozbawiona czegokolwiek z wyjątkiem mechanizmów synchronizacji. Myślę, że właściwym miejscem do umieszczenia "działa" jest klasa, która definiuje funkcję wątku. Zwróć uwagę, że z perspektywy projektowania możesz opuścić wątek przy przerwaniu i nadal nie masz ukończonej pracy. Jeśli chcesz wyczyścić wątek po jego zakończeniu, możesz zawinąć go w bezpieczny wskaźnik i przekazać go klasie robotniczej.