1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
|
// SPDX-FileCopyrightText: Copyright (c) Ken Martin, Will Schroeder, Bill Lorensen
// SPDX-License-Identifier: BSD-3-Clause
#include "vtkThreadedTaskQueue.h"
#include "vtkLogger.h"
#include <chrono>
#include <thread>
int TestThreadedTaskQueue(int, char*[])
{
vtkThreadedTaskQueue<double, int, double> queue(
[](int i, double v) {
vtkLogF(INFO, "hey: %d, %f", i, v);
return i * v;
},
false, 2, 1);
queue.Push(1, 1.0);
queue.Push(2, 2.0);
queue.Push(3, 3.0);
while (!queue.IsEmpty())
{
double r;
if (queue.Pop(r))
{
vtkLogF(INFO, "result: %f", r);
}
else
{
vtkLogF(ERROR, "failed to pop!");
}
}
vtkThreadedTaskQueue<void, int> queue2([](int id) -> void { vtkLogF(INFO, "hi: %d", id); });
queue2.Push(0);
queue2.Push(1);
queue2.Push(2);
queue2.Flush();
return EXIT_SUCCESS;
}
|
