/*
- * Copyright 2014 Facebook, Inc.
+ * Copyright 2015 Facebook, Inc.
*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
}
};
- std::atomic<bool> consumer_stop;
+ DeterministicAtomic<bool> consumer_stop(false);
int consumed = 0;
auto consumer = [&]{
LifoSem a;
LifoSem b;
auto thr = std::thread([&]{
- for (int i = 0; i < iters; ++i) {
+ for (size_t i = 0; i < iters; ++i) {
a.wait();
b.post();
}
});
- for (int i = 0; i < iters; ++i) {
+ for (size_t i = 0; i < iters; ++i) {
a.post();
b.wait();
}
BENCHMARK(lifo_sem_oneway, iters) {
LifoSem a;
auto thr = std::thread([&]{
- for (int i = 0; i < iters; ++i) {
+ for (size_t i = 0; i < iters; ++i) {
a.wait();
}
});
- for (int i = 0; i < iters; ++i) {
+ for (size_t i = 0; i < iters; ++i) {
a.post();
}
thr.join();
BENCHMARK(single_thread_lifo_post, iters) {
LifoSem sem;
- for (int n = 0; n < iters; ++n) {
+ for (size_t n = 0; n < iters; ++n) {
sem.post();
asm volatile ("":::"memory");
}
BENCHMARK(single_thread_lifo_wait, iters) {
LifoSem sem(iters);
- for (int n = 0; n < iters; ++n) {
+ for (size_t n = 0; n < iters; ++n) {
sem.wait();
asm volatile ("":::"memory");
}
BENCHMARK(single_thread_lifo_postwait, iters) {
LifoSem sem;
- for (int n = 0; n < iters; ++n) {
+ for (size_t n = 0; n < iters; ++n) {
sem.post();
asm volatile ("":::"memory");
sem.wait();
BENCHMARK(single_thread_lifo_trywait, iters) {
LifoSem sem;
- for (int n = 0; n < iters; ++n) {
+ for (size_t n = 0; n < iters; ++n) {
EXPECT_FALSE(sem.tryWait());
asm volatile ("":::"memory");
}
BENCHMARK(single_thread_posix_postwait, iters) {
sem_t sem;
EXPECT_EQ(sem_init(&sem, 0, 0), 0);
- for (int n = 0; n < iters; ++n) {
+ for (size_t n = 0; n < iters; ++n) {
EXPECT_EQ(sem_post(&sem), 0);
EXPECT_EQ(sem_wait(&sem), 0);
}
BENCHMARK(single_thread_posix_trywait, iters) {
sem_t sem;
EXPECT_EQ(sem_init(&sem, 0, 0), 0);
- for (int n = 0; n < iters; ++n) {
+ for (size_t n = 0; n < iters; ++n) {
EXPECT_EQ(sem_trywait(&sem), -1);
}
EXPECT_EQ(sem_destroy(&sem), 0);