本文阐释几种用于向 concurrency::call 和 concurrency::transformer 类提供工作函数的方式。
第一个示例演示如何将 lambda 表达式传递给 call 对象。 第二个示例演示如何将函数对象传递给 call 对象。 第三个示例演示如何将类方法绑定到 call 对象。
为了便于说明，本文中的每个示例都使用 call 类。 有关使用 transformer 类的示例，请参阅如何：在数据管道中使用 transformer。
示例：call 类
下面的示例演示了使用 call 类的常用方法。 此示例将一个 lambda 函数传递给 call 构造函数。
// call-lambda.cpp
// compile with: /EHsc
#include <agents.h>
#include <iostream>
using namespace concurrency;
using namespace std;
int wmain()
{
// Stores the result of the computation.
single_assignment<int> result;
// Pass a lambda function to a call object that computes the square
// of its input and then sends the result to the message buffer.
call<int> c([&](int n) {
send(result, n * n);
});
// Send a message to the call object and print the result.
send(c, 13);
wcout << L"13 squared is " << receive(result) << L'.' << endl;
}本示例生成以下输出。
13 squared is 169.示例：使用函数对象的 call 类
下列示例与上一个示例类似，只不过它将 call 类与函数对象一起使用。
// call-functor.cpp
// compile with: /EHsc
#include <agents.h>
#include <iostream>
using namespace concurrency;
using namespace std;
// Functor class that computes the square of its input.
class square
{
public:
explicit square(ITarget<int>& target)
: _target(target)
{
}
// Function call operator for the functor class.
void operator()(int n)
{
send(_target, n * n);
}
private:
ITarget<int>& _target;
};
int wmain()
{
// Stores the result of the computation.
single_assignment<int> result;
// Pass a function object to the call constructor.
square s(result);
call<int> c(s);
// Send a message to the call object and print the result.
send(c, 13);
wcout << L"13 squared is " << receive(result) << L'.' << endl;
}示例：用于绑定 call 对象的函数
下列示例与上一个示例类似，只不过它使用 std::bind1st 和 std::mem_fun 函数将 call 对象绑定到类方法。
如果必须将 call 或 transformer 对象绑定到特定的类方法而不是函数调用运算符 operator()，请使用此方法。
// call-method.cpp
// compile with: /EHsc
#include <agents.h>
#include <functional>
#include <iostream>
using namespace concurrency;
using namespace std;
// Class that computes the square of its input.
class square
{
public:
explicit square(ITarget<int>& target)
: _target(target)
{
}
// Method that computes the square of its input.
void square_value(int n)
{
send(_target, n * n);
}
private:
ITarget<int>& _target;
};
int wmain()
{
// Stores the result of the computation.
single_assignment<int> result;
// Bind a class method to a call object.
square s(result);
call<int> c(bind1st(mem_fun(&square::square_value), &s));
// Send a message to the call object and print the result.
send(c, 13);
wcout << L"13 squared is " << receive(result) << L'.' << endl;
}还可将 bind1st 函数的结果分配给 std::function 对象或使用 auto 关键字，如以下示例所示。
// Assign to a function object.
function<void(int)> f1 = bind1st(mem_fun(&square::square_value), &s);
call<int> c1(f1);
// Alternatively, use the auto keyword to have the compiler deduce the type.
auto f2 = bind1st(mem_fun(&square::square_value), &s);
call<int> c2(f2);
