Method popTask

Source/Common/Async.cpp:290–321

}

bool AsyncThread::popTask(size_t workerIndex, Async*& source, Own<QEvent>& event) {
	Async* self = _process[workerIndex].get();
	if (!self) {
		return false;
	}
	event = self->pollWorkerEvent();
	if (event) {
		source = self;
		return true;
	}
	size_t count = processCount();
	if (count <= 1) {
		return false;
	}
	size_t start = _nextStealFrom.fetch_add(1, std::memory_order_relaxed) % count;
	for (size_t i = 0; i < count; i++) {
		size_t target = (start + i) % count;
		if (target == workerIndex) {
			continue;
		}
		Async* victim = _process[target].get();
		if (!victim) {
			continue;
		}
		event = victim->pollWorkerEvent();
		if (event) {
			source = victim;
			return true;
		}
	}
	return false;
}

void AsyncThread::notifyTaskPosted() {
	_workSemaphore.post();