방법: 데이터 파이프라인에서 transformer 사용
이 항목에는 데이터 파이프라인에서 Concurrency::transformer 클래스를 사용하는 방법을 보여 주는 기본 예제가 포함되어 있습니다. 데이터 파이프라인을 사용하여 이미지 처리를 수행하는 자세한 예제를 보려면 연습: 이미지 처리 네트워크 만들기를 참조하십시오.
데이터 파이프라인은 동시 프로그래밍에서 일반적인 패턴입니다. 데이터 파이프라인은 일련의 단계로 구성되는데, 각 단계에서는 작업을 수행한 후 해당 작업의 결과를 다음 단계로 전달합니다. transformer 클래스는 입력 값을 받고 해당 값에 대한 작업을 수행한 후 다른 구성 요소에서 사용할 수 있도록 결과를 생성하므로 데이터 파이프라인의 핵심 구성 요소입니다.
예제
이 예제에서는 초기 입력 값이 제공된 경우 다음과 같은 데이터 파이프라인을 사용하여 일련의 변환을 수행합니다.
첫 번째 단계에서는 입력 값의 절대값을 계산합니다.
두 번째 단계에서는 입력 값의 제곱근을 계산합니다.
세 번째 단계에서는 입력 값의 제곱을 계산합니다.
네 번째 단계에서는 입력 값을 음수로 만듭니다.
다섯 번째 단계에서는 최종 결과를 메시지 버퍼에 씁니다.
마지막으로 이 예제에서는 파이프라인 결과를 콘솔에 출력합니다.
// data-pipeline.cpp
// compile with: /EHsc
#include <agents.h>
#include <math.h>
#include <iostream>
using namespace Concurrency;
using namespace std;
int wmain()
{
// Computes the absolute value of its input.
transformer<int, int> t0([](int n) {
return abs(n);
});
// Computes the square root of its input.
transformer<int, double> t1([](int n) {
return sqrt(static_cast<double>(n));
});
// Computes the square its input.
transformer<double, int> t2([](double n) {
return static_cast<int>(n * n);
});
// Negates its input.
transformer<int, int> t3([](int n) {
return -n;
});
// Holds the result of the pipeline computation.
single_assignment<int> result;
// Link together each stage of the pipeline.
// t0 -> t1 -> t2 -> t3 -> result
t0.link_target(&t1);
t1.link_target(&t2);
t2.link_target(&t3);
t3.link_target(&result);
// Propagate a message through the pipeline.
send(t0, -42);
// Print the result to the console.
wcout << L"The result is " << receive(result) << L'.' << endl;
}
이 예제는 다음과 같이 출력됩니다.
The result is -42.
데이터 파이프라인의 단계에서는 입력 값과 형식이 다른 값을 출력하는 것이 일반적입니다. 이 예제의 경우 두 번째 단계에서 int 형식의 값을 입력 값으로 사용하고 이 값의 제곱근(double)을 출력 값으로 생성합니다.
참고
이 예제의 데이터 파이프라인은 설명을 위한 것입니다. 각 변환 작업(operation)은 작업(work)을 거의 수행하지 않으므로 메시지 전달을 수행하는 데 필요한 오버헤드가 데이터 파이프라인을 사용하여 얻는 이점보다 클 수 있습니다.
코드 컴파일
예제 코드를 복사하여 Visual Studio 프로젝트 또는 data-pipeline.cpp 파일에 붙여넣고 Visual Studio 2010 명령 프롬프트 창에서 다음 명령을 실행합니다.
cl.exe /EHsc data-pipeline.cpp