#include <iostream>
#include <memory>
#include <vector>
#include "boost/thread.hpp"
using boost::thread;
using std::vector;
using std::unique_ptr;
class ThreadPool {
public:
ThreadPool(int size) : max_size_(size) {}
~ThreadPool() {
Join();
}
void PollForSpace() {
while (static_cast<int>(pool_.size()) >= max_size_) {
for (auto it = pool_.begin(); it != pool_.end(); ++it) {
if ((*it)->timed_join(boost::posix_time::milliseconds(10))) {
pool_.erase(it);
break;
}
}
}
}
void AddToPool(unique_ptr<thread> t) {
pool_.push_back(std::move(t));
}
void Join() {
for (auto it = pool_.begin(); it != pool_.end(); ++it) {
(*it)->join();
}
pool_.clear();
}
protected:
vector<unique_ptr<thread> > pool_;
int max_size_;
};
int main(int argc, char** argv) {
ThreadPool pool(20);
std::vector<int> integers;
for (int i = 0; i < 100; ++i) {
integers.push_back(i);
}
std::cout << "Range based for loop over vector." << std::endl;
for (auto const& i : integers) {
pool.PollForSpace();
pool.AddToPool(unique_ptr<thread>(new thread([&i]{
std::cout << i << std::endl;
})));
}
pool.Join();
std::cout << "Integer loop." << std::endl;
for (int i = 0; i < 100; ++i) {
pool.PollForSpace();
pool.AddToPool(unique_ptr<thread>(new thread([&i]{
std::cout << i << std::endl;
})));
}
pool.Join();
return 0;
}
範囲ベースの for ループが 0 ~ 99 の数字を正しく出力するのはなぜですか (ただし、必ずしも正しい順序であるとは限らず、改行が正しく挿入されない場合もあります) が、整数ループでは次のように出力されます。
1
2
3
4
5
6
7
8
9
13
1414
14
14
15
16
18
18
19
...
99
100
私が理解しているように、整数は参照によってスレッドに渡されますが、スレッドがそれを出力する前にその値がメインループで変更され、一部の値が出力されず、一部の値が出力されます。i
最後のスレッドが作成された後にその値を取得しても、値 100 が出力されます。
ただし、範囲ベースの for ループを使用するときにこれが問題にならない理由がわかりません。
範囲ベースの for ループ バージョンが、このコードの単純な整数ループと同じ同時実行性の問題に悩まされないのはなぜですか?