HomeSort by: relevance | last modified time | path
    Searched refs:WorkQueue (Results 1 - 6 of 6) sorted by relevancy

  /src/external/bsd/zstd/dist/contrib/pzstd/utils/test/
WorkQueueTest.cpp 10 #include "utils/WorkQueue.h"
23 WorkQueue<int>* queue;
37 TEST(WorkQueue, SingleThreaded) {
38 WorkQueue<int> queue;
64 TEST(WorkQueue, SPSC) {
65 WorkQueue<int> queue;
92 TEST(WorkQueue, SPMC) {
93 WorkQueue<int> queue;
115 TEST(WorkQueue, MPMC) {
116 WorkQueue<int> queue
    [all...]
  /src/external/bsd/zstd/dist/contrib/pzstd/
Pzstd.h 18 #include "utils/WorkQueue.h"
111 WorkQueue<std::shared_ptr<BufferWorkQueue>>& chunks,
133 WorkQueue<std::shared_ptr<BufferWorkQueue>>& frames,
150 WorkQueue<std::shared_ptr<BufferWorkQueue>>& outs,
Pzstd.cpp 17 #include "utils/WorkQueue.h"
59 // WorkQueue outlives ThreadPool so in the case of error we are certain
61 WorkQueue<std::shared_ptr<BufferWorkQueue>> outs{options.numThreads + 1};
385 WorkQueue<std::shared_ptr<BufferWorkQueue>>& chunks,
500 WorkQueue<std::shared_ptr<BufferWorkQueue>>& frames,
577 WorkQueue<std::shared_ptr<BufferWorkQueue>>& outs,
  /src/external/bsd/zstd/dist/contrib/pzstd/utils/
WorkQueue.h 26 class WorkQueue {
52 WorkQueue(std::size_t maxSize = 0) : done_(false), maxSize_(maxSize) {}
143 WorkQueue<Buffer> queue_;
ThreadPool.h 11 #include "utils/WorkQueue.h"
23 WorkQueue<std::function<void()>> tasks_;
  /src/external/apache2/llvm/dist/clang/lib/AST/
DeclObjC.cpp 1917 std::queue<const ObjCProtocolDecl *> WorkQueue;
1918 WorkQueue.push(this);
1920 while (!WorkQueue.empty()) {
1921 const auto *PD = WorkQueue.front();
1922 WorkQueue.pop();
1927 WorkQueue.push(Parent);

Completed in 30 milliseconds