| 43 | } |
| 44 | |
| 45 | int ThreadQueues::find_available() |
| 46 | { |
| 47 | #ifdef VERBOSE_QUEUES |
| 48 | cerr << available.size() << " threads in use" << endl; |
| 49 | #endif |
| 50 | if (not available.empty()) |
| 51 | return 0; |
| 52 | for (size_t i = 1; i < size(); i++) |
| 53 | if (at(i)->available()) |
| 54 | available.push_back(i); |
| 55 | #ifdef VERBOSE_QUEUES |
| 56 | cerr << "Using " << available.size() << " threads" << endl; |
| 57 | #endif |
| 58 | return available.size(); |
| 59 | } |
| 60 | |
| 61 | int ThreadQueues::get_n_per_thread(int n_items, int granularity) |
| 62 | { |