Method Impl

src/ll/api/thread/ThreadPoolExecutor.cpp:78–100

        return *scheduledWorker;
    }
    Impl(Executor& self, size_t nThreads) {
        for (size_t i = 0; i < nThreads; ++i) {
            workers.emplace_back([this, &self, i] {
                setThreadName(fmt::format("{}[{}]", self.getName(), i));
                decltype(tasks)::consumer_token_t token{tasks};
                for (;;) {
                    std::function<void()> task;
                    taskCount.acquire();
                    while (!tasks.try_dequeue(token, task)) {
                        if (stop.load(std::memory_order_relaxed)) {
                            return;
                        }
                    }
                    try {
                        task();
                    } catch (...) {
                        getLogger().error("Error in {}[{}]:", self.getName(), i);
                        error_utils::printCurrentException(getLogger());
                    }
                }
            });
        }
    }
    ~Impl() {
        stop = true;
        taskCount.release(workers.size());