Commit efedb1ae authored by gbalduzz's avatar gbalduzz
Browse files

Fixed thread affinity assignement.

parent 01f91d33

src/parallel/stdthread/thread_pool/thread_pool.cpp

+2 −2
Original line number Diff line number Diff line
@@ -63,10 +63,10 @@ void ThreadPool::enlarge(size_t n_threads) { 


void ThreadPool::workerLoop(int id) {

  // Set affinity.

  const int shift = core_count_ * id;

  const int shift = master_affinity_.size() * id;

  std::vector<int> affinities;

  for (int x : master_affinity_)

    affinities.push_back(x + shift);

    affinities.push_back((x + shift) % core_count_);



  set_affinity(affinities);