Method run

test/core/ThreadPoolTest.cpp:19–43

public:
    virtual ~ThreadPoolTest() = default;
    virtual bool run(int precision) {
        std::vector<std::thread> threads;
        for (int i = 0; i < 10; ++i) {
            threads.emplace_back([i]() {
                MNN::ThreadPool* threadPool = nullptr;
                MNN::ThreadPool::init(10 - i, 0, threadPool);
                // initializer
                auto workIndex = threadPool->acquireWorkIndex();
                FUNC_PRINT(workIndex);
                threadPool->active();
                ThreadPool::TASK task = std::make_pair([](int index) {
                    FUNC_PRINT(index);
                    std::this_thread::yield();
                }, 10);
                threadPool->enqueue(&task, workIndex);
                threadPool->deactive();
                threadPool->releaseWorkIndex(workIndex);
            });
        }
        for (auto& t : threads) {
            t.join();
        }
        MNN::ThreadPool::destroy();
        return true;
    }
};

MNNTestSuiteRegister(ThreadPoolTest, "core/threadpool");