Практическое руководство. Выбор среди завершенных задач
В это примере показано, как с помощью классов concurrency::choice и concurrency::join выбрать первую задачу для завершения алгоритма поиска.
Пример
В следующем примере параллельно выполняются два алгоритма поиска, для завершения выбирается первый алгоритм. В этом примере определяется тип employee, который содержит числовой идентификатор и зарплату сотрудника. С помощью функции find_employee осуществляется поиск первого сотрудника, имеющего предоставленный идентификатор или зарплату. Функция find_employee также обрабатывает случай, когда ни один из сотрудников не имеет предоставленный идентификатор или зарплату. Функция wmain создает массив объектов employee и выполняет поиск нескольких значений идентификатора и зарплаты.
В этом примере объект choice используется для выбора одного из следующих случаев.
Сотрудник с предоставленным идентификатором существует.
Сотрудник с предоставленной зарплатой существует.
Сотрудника с предоставленным идентификатором или зарплатой не существует.
Для первых двух случаев в этом примере объект concurrency::single_assignment содержит идентификатор, а другой объект single_assignment — зарплату. В этом примере для третьего случая используется объект join. Объект join состоит из двух дополнительных объектов single_assignment: один для случая, когда не существует сотрудника с предоставленным идентификатором, другой — для случая, когда не существует сотрудника с предоставленной зарплатой. Объект join отправляет сообщение, когда каждый из его членов получает сообщение. В этом примере объект join отправляет сообщение, если не существует сотрудника с предоставленным идентификатором или зарплатой.
В этом примере объект concurrency::structured_task_group используется для параллельного выполнения обоих алгоритмов поиска. Каждая задача поиска записывает данные в один из объектов single_assignment, чтобы указать, существует ли заданный сотрудник. В примере для получения индекса первого буфера, который содержит сообщение и блок switch для вывода результата, используется функция concurrency::receive.
// find-employee.cpp
// compile with: /EHsc
#include <agents.h>
#include <ppl.h>
#include <array>
#include <iostream>
#include <random>
using namespace concurrency;
using namespace std;
// Contains information about an employee.
struct employee
{
int id;
float salary;
};
// Finds the first employee that has the provided id or salary.
template <typename T>
void find_employee(const T& employees, int id, float salary)
{
// Holds the salary for the employee with the provided id.
single_assignment<float> find_id_result;
// Holds the id for the employee with the provided salary.
single_assignment<int> find_salary_result;
// Holds a message if no employee with the provided id exists.
single_assignment<bool> id_not_found;
// Holds a message if no employee with the provided salary exists.
single_assignment<bool> salary_not_found;
// Create a join object for the "not found" buffers.
// This join object sends a message when both its members holds a message
// (in other words, no employee with the provided id or salary exists).
auto not_found = make_join(&id_not_found, &salary_not_found);
// Create a choice object to select among the following cases:
// 1. An employee with the provided id exists.
// 2. An employee with the provided salary exists.
// 3. No employee with the provided id or salary exists.
auto selector = make_choice(&find_id_result, &find_salary_result, ¬_found);
// Create a task that searches for the employee with the provided id.
auto search_id_task = make_task([&]{
auto result = find_if(begin(employees), end(employees),
[&](const employee& e) { return e.id == id; });
if (result != end(employees))
{
// The id was found, send the salary to the result buffer.
send(find_id_result, result->salary);
}
else
{
// The id was not found.
send(id_not_found, true);
}
});
// Create a task that searches for the employee with the provided salary.
auto search_salary_task = make_task([&]{
auto result = find_if(begin(employees), end(employees),
[&](const employee& e) { return e.salary == salary; });
if (result != end(employees))
{
// The salary was found, send the id to the result buffer.
send(find_salary_result, result->id);
}
else
{
// The salary was not found.
send(salary_not_found, true);
}
});
// Use a structured_task_group object to run both tasks.
structured_task_group tasks;
tasks.run(search_id_task);
tasks.run(search_salary_task);
wcout.setf(ios::fixed, ios::fixed);
wcout.precision(2);
// Receive the first object that holds a message and print a message.
int index = receive(selector);
switch (index)
{
case 0:
wcout << L"Employee with id " << id << L" has salary "
<< receive(find_id_result);
break;
case 1:
wcout << L"Employee with salary " << salary << L" has id "
<< receive(find_salary_result);
break;
case 2:
wcout << L"No employee has id " << id << L" or salary " << salary;
break;
default:
__assume(0);
}
wcout << L'.' << endl;
// Cancel any active tasks and wait for the task group to finish.
tasks.cancel();
tasks.wait();
}
int wmain()
{
// Create an array of employees and assign each one a
// random id and salary.
array<employee, 10000> employees;
mt19937 gen(15);
const float base_salary = 25000.0f;
for (int i = 0; i < employees.size(); ++i)
{
employees[i].id = gen()%100000;
float bonus = static_cast<float>(gen()%5000);
employees[i].salary = base_salary + bonus;
}
// Search for several id and salary values.
find_employee(employees, 14758, 30210.00);
find_employee(employees, 340, 29150.00);
find_employee(employees, 61935, 29255.90);
find_employee(employees, 899, 31223.00);
}
В результате выполнения примера получается следующий результат:
В этом примере вспомогательная функция concurrency::make_choice используется для создания объектов choice, а вспомогательная функция concurrency::make_join — для создания объектов join.
Компиляция кода
Скопируйте код примера и вставьте его в проект Visual Studio или в файл с именем find-employee.cpp, затем выполните в окне командной строки Visual Studio следующую команду.
cl.exe /EHsc find-employee.cpp