Searched refs:threadPool (Results 1 – 5 of 5) sorted by relevance
101 llvm::ThreadPool *threadPool) { in processBuffer() argument109 if (threadPool) in processBuffer()110 context.setThreadPool(*threadPool); in processBuffer()152 ThreadPool *threadPool = nullptr; in MlirOptMain() local160 threadPool = &threadPoolCtx.getThreadPool(); in MlirOptMain()167 threadPool); in MlirOptMain()
69 llvm::ThreadPool &threadPool = context->getThreadPool(); in failableParallelForEach() local70 llvm::ThreadPoolTaskGroup tasksGroup(threadPool); in failableParallelForEach()71 size_t numActions = std::min(numElements, threadPool.getThreadCount()); in failableParallelForEach()
167 llvm::ThreadPool *threadPool = nullptr; member in mlir::MLIRContextImpl244 threadPool = ownedThreadPool.get(); in MLIRContextImpl()514 assert(impl->threadPool); in disableMultithreading()515 impl->threadPool = nullptr; in disableMultithreading()518 } else if (!impl->threadPool) { in disableMultithreading()522 impl->threadPool = impl->ownedThreadPool.get(); in disableMultithreading()529 impl->threadPool = &pool; in setThreadPool()536 assert(impl->threadPool && in getNumThreads()538 return impl->threadPool->getThreadCount(); in getNumThreads()547 assert(impl->threadPool && in getThreadPool()[all …]
53 threadPool.wait(); // wait for the completion of all async tasks in ~AsyncRuntime()62 llvm::ThreadPool &getThreadPool() { return threadPool; } in getThreadPool()77 llvm::ThreadPool threadPool; member in mlir::runtime::__anonc7b155b40111::AsyncRuntime
69 ThreadPool threadPool; member in __anona61fce6f0111::Writer1055 threadFutures.emplace_back(threadPool.async( in finalizeLinkEditSegment()1126 threadFutures.emplace_back(threadPool.async( in writeUuid()1193 threadPool.async([&] { in run()