|
|
@ -6,7 +6,6 @@
|
|
|
|
|
|
|
|
|
|
|
|
#include <array>
|
|
|
|
#include <array>
|
|
|
|
#include <deque>
|
|
|
|
#include <deque>
|
|
|
|
#include <boost/range/algorithm_ext/erase.hpp>
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
namespace Common {
|
|
|
|
namespace Common {
|
|
|
|
|
|
|
|
|
|
|
@ -111,8 +110,9 @@ struct ThreadQueueList {
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
void remove(Priority priority, const T& thread_id) {
|
|
|
|
void remove(Priority priority, const T& thread_id) {
|
|
|
|
Queue* cur = &queues[priority];
|
|
|
|
Queue* const cur = &queues[priority];
|
|
|
|
boost::remove_erase(cur->data, thread_id);
|
|
|
|
const auto iter = std::remove(cur->data.begin(), cur->data.end(), thread_id);
|
|
|
|
|
|
|
|
cur->data.erase(iter, cur->data.end());
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
void rotate(Priority priority) {
|
|
|
|
void rotate(Priority priority) {
|
|
|
|