Lines Matching defs:TaskQueue
23 TaskQueue::TaskQueue(ExecutorPool *m, task_type_t t, const char *nm) :
29 TaskQueue::~TaskQueue() {
33 const std::string TaskQueue::getName() const {
37 ExTask TaskQueue::_popReadyTask(void) {
44 void TaskQueue::doWake(size_t &numToWake) {
49 void TaskQueue::_doWake_UNLOCKED(size_t &numToWake) {
62 bool TaskQueue::_doSleep(ExecutorThread &t) {
94 bool TaskQueue::_fetchNextTask(ExecutorThread &t, bool toSleep) {
115 // if this TaskQueue has obtained capacity for the thread, then we must
140 bool TaskQueue::fetchNextTask(ExecutorThread &thread, bool toSleep) {
147 size_t TaskQueue::_moveReadyTasks(struct timeval tv) {
170 void TaskQueue::_checkPendingQueue(void) {
179 struct timeval TaskQueue::_reschedule(ExTask &task, task_type_t &curTaskType) {
195 struct timeval TaskQueue::reschedule(ExTask &task, task_type_t &curTaskType) {
202 void TaskQueue::_schedule(ExTask &task) {
211 TaskQueue *sleepQ = manager->getSleepQ(queueType);
219 void TaskQueue::schedule(ExTask &task) {
225 void TaskQueue::_wake(ExTask &task) {
272 TaskQueue *sleepQ = manager->getSleepQ(queueType);
280 void TaskQueue::wake(ExTask &task) {
286 const std::string TaskQueue::taskType2Str(task_type_t type) {