Como: criar uma tarefa é concluída após um atraso
Este exemplo mostra como usar concurrency::task, concurrency::cancellation_token_source, concurrency::cancellation_token, concurrency::task_completion_event, concurrency::timer, e classes de concurrency::call para criar uma tarefa que termine após um atraso.Você pode usar esse método para compilar os loop que sondam ocasionalmente para dados, apresenta o tempo limite, manipulação de atraso de entrada do usuário por um período predeterminados, e assim por diante.
Exemplo
O exemplo a seguir mostra as funções de complete_after e de cancel_after_timeout .A função de complete_after cria um objeto de task terminar depois que o atraso especificado.Usa um objeto de timer e um objeto de call para definir um objeto de task_completion_event depois que o atraso especificado.Usando a classe de task_completion_event , você pode definir uma tarefa que termine depois que um segmento ou outra tarefa sinalizam que um valor está disponível.Quando o evento é definido, as tarefas de ouvinte completa e suas continuações são agendadas para executar.
.gif "Dica") Dica |
|---|
Para obter mais informações sobre as classes de timer e de call , que são parte da biblioteca assíncrona de agentes, consulte Blocos assíncronas de mensagem. |
As compilações de função de cancel_after_timeout em complete_after funciona para cancelar uma tarefa se essa tarefa não termina antes de um tempo limite especificado.A função de cancel_after_timeout cria duas tarefas.A primeira tarefa indica êxito e conclua depois que a tarefa fornecida completa; a segunda tarefa indica a falha e após concluir o tempo limite especificado.A função de cancel_after_timeout cria uma tarefa de continuação de linha que executa quando a tarefa de êxito ou falha de concluir.Se a tarefa de falha concluir a seguir primeiro, cancela a origem de token para cancelar a tarefa geral.
// Creates a task that completes after the specified delay.
task<void> complete_after(unsigned int timeout)
{
// A task completion event that is set when a timer fires.
task_completion_event<void> tce;
// Create a non-repeating timer.
auto fire_once = new timer<int>(timeout, 0, nullptr, false);
// Create a call object that sets the completion event after the timer fires.
auto callback = new call<int>([tce](int)
{
tce.set();
});
// Connect the timer to the callback and start the timer.
fire_once->link_target(callback);
fire_once->start();
// Create a task that completes after the completion event is set.
task<void> event_set(tce);
// Create a continuation task that cleans up resources and
// and return that continuation task.
return event_set.then([callback, fire_once]()
{
delete callback;
delete fire_once;
});
}
// Cancels the provided task after the specifed delay, if the task
// did not complete.
template<typename T>
task<T> cancel_after_timeout(task<T> t, cancellation_token_source cts, unsigned int timeout)
{
// Create a task that returns true after the specified task completes.
task<bool> success_task = t.then([](T)
{
return true;
});
// Create a task that returns false after the specified timeout.
task<bool> failure_task = complete_after(timeout).then([]
{
return false;
});
// Create a continuation task that cancels the overall task
// if the timeout task finishes first.
return (failure_task || success_task).then([t, cts](bool success)
{
if(!success)
{
// Set the cancellation token. The task that is passed as the
// t parameter should respond to the cancellation and stop
// as soon as it can.
cts.cancel();
}
// Return the original task.
return t;
});
}
O exemplo a seguir calcula a contagem de números primos no intervalo 0, 100000 [] várias vezes.A operação falhará se não termina em um limite de tempo especificado.A função de count_primes demonstra como usar a função de cancel_after_timeout .Conta o número de apronta em determinado intervalo e falhará se a tarefa não termina no tempo fornecidos.As chamadas de função de wmain a função de count_primes várias vezes.Cada vez, parte ao meio o limite de tempo.O programa após concluir a operação não termina no limite de hora atual.
// Determines whether the input value is prime.
bool is_prime(int n)
{
if (n < 2)
return false;
for (int i = 2; i < n; ++i)
{
if ((n % i) == 0)
return false;
}
return true;
}
// Counts the number of primes in the range [0, max_value].
// The operation fails if it exceeds the specified timeout.
bool count_primes(unsigned int max_value, unsigned int timeout)
{
cancellation_token_source cts;
// Create a task that computes the count of prime numbers.
// The task is canceled after the specified timeout.
auto t = cancel_after_timeout(task<size_t>([max_value, timeout]
{
combinable<size_t> counts;
parallel_for<unsigned int>(0, max_value + 1, [&counts](unsigned int n)
{
// Respond if the overall task is cancelled by canceling
// the current task.
if (is_task_cancellation_requested())
{
cancel_current_task();
}
// NOTE: You can replace the calls to is_task_cancellation_requested
// and cancel_current_task with a call to interruption_point.
// interruption_point();
// Increment the local counter if the value is prime.
if (is_prime(n))
{
counts.local()++;
}
});
// Return the sum of counts across all threads.
return counts.combine(plus<size_t>());
}, cts.get_token()), cts, timeout);
// Print the result.
try
{
auto primes = t.get();
wcout << L"Found " << primes << L" prime numbers within "
<< timeout << L" ms." << endl;
return true;
}
catch (const task_canceled& e)
{
wcout << L"The task timed out." << endl;
return false;
}
}
int wmain()
{
// Compute the count of prime numbers in the range [0, 100000]
// until the operation fails.
// Each time the test succeeds, the time limit is halved.
unsigned int max = 100000;
unsigned int timeout = 5000;
bool success = true;
do
{
success = count_primes(max, timeout);
timeout /= 2;
} while (success);
}
/* Sample output:
Found 9592 prime numbers within 5000 ms.
Found 9592 prime numbers within 2500 ms.
Found 9592 prime numbers within 1250 ms.
Found 9592 prime numbers within 625 ms.
The task timed out.
*/
Quando você usar essa técnica cancelar tarefas após um atraso, nenhuma tarefas unstarted não iniciará depois que a tarefa geral é cancelada.No entanto, é importante para que todas as tarefas longas respondam ao cancelar em tempo hábil.Nesse exemplo, o método de count_primes chama funções de concurrency::is_task_cancellation_requested e de cancel_current_task para responder a cancelar.(Como alternativa, você pode chamar a função de concurrency::interruption_point ).Para obter mais informações sobre cancelar de tarefas, consulte Cancelar o PPL.
Aqui está o código completo para este exemplo:
// task-delay.cpp
// compile with: /EHsc
#include <ppltasks.h>
#include <agents.h>
#include <iostream>
using namespace concurrency;
using namespace std;
// Creates a task that completes after the specified delay.
task<void> complete_after(unsigned int timeout)
{
// A task completion event that is set when a timer fires.
task_completion_event<void> tce;
// Create a non-repeating timer.
auto fire_once = new timer<int>(timeout, 0, nullptr, false);
// Create a call object that sets the completion event after the timer fires.
auto callback = new call<int>([tce](int)
{
tce.set();
});
// Connect the timer to the callback and start the timer.
fire_once->link_target(callback);
fire_once->start();
// Create a task that completes after the completion event is set.
task<void> event_set(tce);
// Create a continuation task that cleans up resources and
// and return that continuation task.
return event_set.then([callback, fire_once]()
{
delete callback;
delete fire_once;
});
}
// Cancels the provided task after the specifed delay, if the task
// did not complete.
template<typename T>
task<T> cancel_after_timeout(task<T> t, cancellation_token_source cts, unsigned int timeout)
{
// Create a task that returns true after the specified task completes.
task<bool> success_task = t.then([](T)
{
return true;
});
// Create a task that returns false after the specified timeout.
task<bool> failure_task = complete_after(timeout).then([]
{
return false;
});
// Create a continuation task that cancels the overall task
// if the timeout task finishes first.
return (failure_task || success_task).then([t, cts](bool success)
{
if(!success)
{
// Set the cancellation token. The task that is passed as the
// t parameter should respond to the cancellation and stop
// as soon as it can.
cts.cancel();
}
// Return the original task.
return t;
});
}
// Determines whether the input value is prime.
bool is_prime(int n)
{
if (n < 2)
return false;
for (int i = 2; i < n; ++i)
{
if ((n % i) == 0)
return false;
}
return true;
}
// Counts the number of primes in the range [0, max_value].
// The operation fails if it exceeds the specified timeout.
bool count_primes(unsigned int max_value, unsigned int timeout)
{
cancellation_token_source cts;
// Create a task that computes the count of prime numbers.
// The task is canceled after the specified timeout.
auto t = cancel_after_timeout(task<size_t>([max_value, timeout]
{
combinable<size_t> counts;
parallel_for<unsigned int>(0, max_value + 1, [&counts](unsigned int n)
{
// Respond if the overall task is cancelled by canceling
// the current task.
if (is_task_cancellation_requested())
{
cancel_current_task();
}
// NOTE: You can replace the calls to is_task_cancellation_requested
// and cancel_current_task with a call to interruption_point.
// interruption_point();
// Increment the local counter if the value is prime.
if (is_prime(n))
{
counts.local()++;
}
});
// Return the sum of counts across all threads.
return counts.combine(plus<size_t>());
}, cts.get_token()), cts, timeout);
// Print the result.
try
{
auto primes = t.get();
wcout << L"Found " << primes << L" prime numbers within "
<< timeout << L" ms." << endl;
return true;
}
catch (const task_canceled& e)
{
wcout << L"The task timed out." << endl;
return false;
}
}
int wmain()
{
// Compute the count of prime numbers in the range [0, 100000]
// until the operation fails.
// Each time the test succeeds, the time limit is halved.
unsigned int max = 100000;
unsigned int timeout = 5000;
bool success = true;
do
{
success = count_primes(max, timeout);
timeout /= 2;
} while (success);
}
/* Sample output:
Found 9592 prime numbers within 5000 ms.
Found 9592 prime numbers within 2500 ms.
Found 9592 prime numbers within 1250 ms.
Found 9592 prime numbers within 625 ms.
The task timed out.
*/
Compilando o código
Para compilar o código, copie e cole-o em um projeto Visual Studio, ou colagem em um arquivo chamado task-delay.cpp e executado no seguinte comando em uma janela de prompt de comando Visual Studio.
cl.exe /EHsc task-delay.cpp
Consulte também
Referência
a classe (Runtime de simultaneidade) de tarefas.
cancellation_token_source classe
Função de is_task_cancellation_requested
Conceitos
Paralelismo de tarefa (tempo de execução de simultaneidade)