Method AsyncThread

Source/Common/Async.cpp:236–248

// AsyncThread

AsyncThread::AsyncThread()
	: _nextProcess(0)
	, _nextStealFrom(0)
	, _stopping(false)
	, _process(std::max(std::thread::hardware_concurrency(), 4u) - 1) {
	for (int i = 0; i < s_cast<int>(_process.size()); i++) {
		_process[i] = New<Async>();
		_process[i]->bindPool(this, s_cast<size_t>(i));
	}
	for (int i = 0; i < s_cast<int>(_process.size()); i++) {
		_process[i]->initThreadOnce();
	}
}

AsyncThread::~AsyncThread() {
	cancel();