방법: 완료된 작업 간 선택

아티클
05/01/2013

사용 하는 방법을 보여 주는이 예제는 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 개체 중 하나에 씁니다.예제를 사용 하는 concurrency::receive 함수는 첫 번째 메시지를 포함 하는 버퍼의 인덱스를 구하려면 a switch 결과 인쇄 하려면 블록.

// 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, &not_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);
}

이 예제의 결과는 다음과 같습니다.

Employee with id 14758 has salary 27780.00.
Employee with salary 29150.00 has id 84345.
Employee with id 61935 has salary 29905.00.
No employee has id 899 or salary 31223.00.

이 예제는 concurrency::make_choice 도우미 함수를 만들려면 choice 개체 및 concurrency::make_join 도우미 함수를 만들려면 join 개체.