Searched refs:WorkQueue (Results 1 – 7 of 7) sorted by relevance
| /freebsd-12.1/sys/contrib/zstd/contrib/pzstd/utils/test/ |
| H A D | WorkQueueTest.cpp | 23 WorkQueue<int>* queue;
38 WorkQueue<int> queue; in TEST()
64 TEST(WorkQueue, SPSC) { in TEST() argument
65 WorkQueue<int> queue; in TEST()
92 TEST(WorkQueue, SPMC) { in TEST() argument
93 WorkQueue<int> queue; in TEST()
115 TEST(WorkQueue, MPMC) { in TEST() argument
116 WorkQueue<int> queue; in TEST()
151 WorkQueue<int> queue(1); in TEST()
164 WorkQueue<int> queue(1); in TEST()
[all …]
|
| /freebsd-12.1/sys/contrib/zstd/contrib/pzstd/ |
| H A D | Pzstd.h | 108 WorkQueue<std::shared_ptr<BufferWorkQueue>>& chunks,
130 WorkQueue<std::shared_ptr<BufferWorkQueue>>& frames,
147 WorkQueue<std::shared_ptr<BufferWorkQueue>>& outs,
|
| H A D | Pzstd.cpp | 66 WorkQueue<std::shared_ptr<BufferWorkQueue>> outs{options.numThreads + 1}; in handleOneInput()
386 WorkQueue<std::shared_ptr<BufferWorkQueue>>& chunks, in asyncCompressChunks()
501 WorkQueue<std::shared_ptr<BufferWorkQueue>>& frames, in asyncDecompressFrames()
578 WorkQueue<std::shared_ptr<BufferWorkQueue>>& outs, in writeFile()
|
| /freebsd-12.1/sys/contrib/zstd/contrib/pzstd/utils/ |
| H A D | WorkQueue.h | 26 class WorkQueue {
52 WorkQueue(std::size_t maxSize = 0) : done_(false), maxSize_(maxSize) {} in done_()
143 WorkQueue<Buffer> queue_;
|
| H A D | ThreadPool.h | 23 WorkQueue<std::function<void()>> tasks_;
|
| H A D | BUCK | 58 exported_headers=['WorkQueue.h'],
|
| /freebsd-12.1/contrib/llvm/lib/Transforms/Scalar/ |
| H A D | EarlyCSE.cpp | 618 SmallVector<MemoryAccess *, 8> WorkQueue; in removeMSSA() local
619 WorkQueue.push_back(MA); in removeMSSA()
623 for (unsigned I = 0; I < WorkQueue.size(); ++I) { in removeMSSA()
624 MemoryAccess *WI = WorkQueue[I]; in removeMSSA()
636 WorkQueue.push_back(MP); in removeMSSA()
|