blob: feb0342086162deb81cb3fa67788ef8ce65d28eb (
plain)
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
|
#include <gtest/gtest.h>
#include "tensorflow/core/lib/core/blocking_counter.h"
#include "tensorflow/core/lib/core/threadpool.h"
namespace tensorflow {
namespace {
TEST(BlockingCounterTest, TestZero) {
BlockingCounter bc(0);
bc.Wait();
}
TEST(BlockingCounterTest, TestSingleThread) {
BlockingCounter bc(2);
bc.DecrementCount();
bc.DecrementCount();
bc.Wait();
}
TEST(BlockingCounterTest, TestMultipleThread) {
int N = 3;
thread::ThreadPool* thread_pool =
new thread::ThreadPool(Env::Default(), "test", N);
BlockingCounter bc(N);
for (int i = 0; i < N; ++i) {
thread_pool->Schedule([&bc] { bc.DecrementCount(); });
}
bc.Wait();
delete thread_pool;
}
} // namespace
} // namespace tensorflow
|
