Boost Thread - Comment reconnaître une interruption

J'ai le blocage des tâches qui seront exécutées par des find_the_question() fonction. Cependant, je ne veux pas le fil de l'exécution de cette fonction prendre plus de 10 secondes. Donc, dans le cas où il prend plus de 10 secondes, je veux fermer ce thread avec le nettoyage de toutes les ressources.

J'ai essayé d'écrire un code pour que, mais de toute façon je ne suis pas en mesure d'obtenir une interruption dans find_the_question() la fonction si thread prend plus de 10 secondes. Pourriez-vous s'il vous plaît dites-moi ce que je fais mal?

void find_the_question(std::string value)
{
    //allocate x resources
    try{
        //do some process on resources
            sleep(14);
        //clean resources
    }
    catch(boost::thread_interrupted const& )
    {
        //clean resources
        std::cout << "Worker thread interrupted" << std::endl;
    }
}

int main()
{
        boost::posix_time::time_duration timeout = boost::posix_time::milliseconds(10000);
        std::cout << "In main" << std::endl;
        boost::thread t1(find_the_question, "Can you block me");

        t1.interrupt();
        if (t1.timed_join(timeout))
        {
          //finished
          std::cout << "Worker thread finished" << std::endl;
        }
        else
        {
          //Not finished;
          std::cout << "Worker thread not finished" << std::endl;
        }

        std::cout << "In main end" << std::endl;
}

De sortie:
Si t1 prend plus de 10 secondes pour terminer, je reçois suite à la sortie de console.

std::cout << "In main" << std::endl;
std::cout << "Worker thread not finished" << std::endl;
std::cout << "In main end" << std::endl;

alors que j'attends la suite de la sortie

std::cout << "In main" << std::endl;
std::cout << "Worker thread interrupted" << std::endl;
std::cout << "Worker thread not finished" << std::endl;
std::cout << "In main end" << std::endl;

Pourriez-vous s'il vous plaît dites-moi ce que je fais mal.

Merci d'avance

source d'informationauteur Amey Jah

  1. 25

    Pour utiliser boost::thread::interrupt(), vous devez utiliser boost::thread::sleep() pour qu'il fonctionne.

    Un thread en cours d'exécution peut être interrompue par l'invocation de la interrupt() membre
    la fonction de correspondant boost::thread de l'objet. Lorsque l'
    filet interrompu suivant exécute une ou de l'interruption
    points (ou si elle est actuellement bloqué, tout en exécutant un) avec
    interruption activée, puis un coup de fouet::thread_interrupted exception
    être jeté dans le filet interrompu. Si pas pris, ce sera la cause de
    l'exécution de l'interruption du fil à la fin. Comme avec n'importe quel
    autre exception, la pile sera dénoué, et destructeurs
    les objets de stockage automatique de la durée sera exécuté

    Prédéfinis interruption points:

    Les fonctions suivantes sont d'interruption de points, qui vont se jeter
    boost::thread_interrupted si l'interruption est activé pour l'
    fil, et l'interruption est demandée pour le thread courant:

    boost::thread::join()
boost::thread::timed_join()
boost::condition_variable::wait()
boost::condition_variable::timed_wait()
boost::condition_variable_any::wait()
boost::condition_variable_any::timed_wait()
boost::thread::sleep()
boost::this_thread::sleep()
boost::this_thread::interruption_point()