C++11 future.wait_for() всегда возвращает future_status::timeout

У меня есть программа на C++11, которая проверяет, является ли число простым. Есть будущий объект, который программа ожидает, чтобы быть готовым. После завершения программа сообщает, считает ли функция поставщика будущего объекта число простым.

// future example
#include <iostream>       // std::cout
#include <future>         // std::async, std::future
#include <chrono>         // std::chrono::milliseconds


const int number = 4; // 444444443

// a non-optimized way of checking for prime numbers:
bool is_prime (int x) {
    for (int i=2; i<x; ++i) if (x%i==0) return false;
      return true;
    }

int main ()
{
    // call function asynchronously:
    std::future<bool> fut = std::async (is_prime, number); 

    // do something while waiting for function to set future:
    std::cout << "checking, please wait";
    std::chrono::milliseconds span (100);
    //std::chrono::duration<int> span (1);

    while (fut.wait_for(span)==std::future_status::timeout) {
        std::cout << '.';
        std::cout.flush();
    }

    bool x = fut.get();     // retrieve return value

    std::cout << "\n"<<number<<" " << (x?"is":"is not") << " prime.\n";

    return 0;
}

Если вы запустите программу, вы увидите, что она находится в бесконечном цикле while, так как wait_for() всегда возвращается future_status::timeout, что означает, что общее состояние никогда не готово. В чем причина этого? Я взял эту программу с http://www.cplusplus.com/reference/future/future/wait_for/, поэтому ожидал, что она будет работать. Однако, если я закомментирую цикл while, программа будет работать нормально.

Источник

2 ответа

Решение

Код работает: (g ++ 4.9, clang 3.4) http://coliru.stacked-crooked.com/a/f3c2530c96591724

Я получаю то же поведение, что и вы с MINGW32 с g++ 4.8.1. Установка политики явно std::launch::async решает проблему.
(То есть: std::async(std::launch::async, is_prime, number);)

Источник

Не уверен, что это ошибка в компиляторе, но я считаю, что wait_for должен возвращаться future_status::deferred Это именно то, что Скотт Майерс обсуждает в своей книге Effective C++ в Item 36:Specify std::launch::async if asynchronicity is essential

И решение, которое он предлагает

Исправление простое: просто проверьте будущее, соответствующее вызову std::async, чтобы увидеть, отложена ли задача, и, если это так, избегайте входа в цикл на основе тайм-аута. К сожалению, нет прямого способа спросить будущее, отложена ли его задача. Вместо этого вы должны вызвать основанную на тайм-ауте функцию, такую ​​как wait_for. В этом случае вам не нужно ничего ждать, вы просто хотите увидеть, является ли возвращаемое значение std::future_status::deferred, так что подавите свое легкое недоверие при необходимом обходе и вызовите wait_for с нулевым тайм-аутом.

В вашем случае, вы можете явно указать асинхронность, как @Jarod упомянул в своем решении, т.е. std::launch::async Или вы можете переписать свой код, как показано ниже

bool x;
// if task is deferred...
if (fut.wait_for(std::chrono::milliseconds(0)) == std::future_status::deferred)
{
 // ...use wait or get on fut
 // to call is_prime synchronously
   x = fut.get();     // retrieve return value
}
else { // task isn't deferred
 // infinite loop not possible (assuming is_prime finishes)
 while (fut.wait_for(span) != std::future_status::ready) { 
     // task is neither deferred nor ready,
     // so do concurrent work until it's ready
     std::cout << '.';
     std::cout.flush();
 }
 // fut is ready
 x = fut.get();     // retrieve return value
}

http://coliru.stacked-crooked.com/a/cb4e4b3f642f79f5

Источник
Другие вопросы по тегам