次のコードはC++11で機能し、複数Worker::foo()
のを並行して実行する必要があります。
#include <thread>
#include <memory>
#include <vector>
struct Worker
{
void foo();
};
int main()
{
std::vector<std::unique_ptr<Worker>> workers;
std::vector<std::thread> threads;
workers.reserve(N);
threads.reserve(N);
for (unsigned int i = 0; i != N; ++i)
{
workers.emplace_back(new Worker);
threads.emplace_back(&Worker::foo, workers.back().get());
}
// ... later ...
for (auto & t : threads) { t.join(); }
}
要素参照が有効であり続けると信頼できる場合は、一意のポインターがなくても実行できます。
std::deque<Worker> workers;
// ...
for (unsigned int i = 0; i != N; ++i)
{
workers.emplace_back(); // pray this doesn't invalidate
threads.emplace_back(&Worker::foo, std::ref(workers.back()));
}