Method ThreadPool

tenseal/cpp/utils/threadpool.h:36–48

* Create "n_threads" workers, each with a dedicated task queue, and execute * the task as they arrive in the queues. **/

     * the task as they arrive in the queues.
     **/
    ThreadPool(unsigned int n_threads = get_concurrency())
        : m_queues(n_threads), m_count(n_threads) {
        assert(n_threads != 0);
        auto worker = [&](unsigned int i) {
            while (true) {
                Proc f;
                if (!m_queues[i].pop(f)) break;
                f();
            }
        };
        for (unsigned int i = 0; i < n_threads; ++i)
            m_workers.emplace_back(worker, i);
    }

    ~ThreadPool() noexcept {
        for (auto& queue : m_queues) queue.done();