/*
- * Copyright 2014 Facebook, Inc.
+ * Copyright 2016 Facebook, Inc.
*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
* limitations under the License.
*/
-#include "folly/LifoSem.h"
-#include "folly/test/DeterministicSchedule.h"
+#include <folly/LifoSem.h>
-#include <thread>
#include <semaphore.h>
-#include <gflags/gflags.h>
-#include <gtest/gtest.h>
+#include <thread>
-#include "folly/Benchmark.h"
-#include "folly/Random.h"
+#include <folly/Benchmark.h>
+#include <folly/Random.h>
+#include <folly/portability/Asm.h>
+#include <folly/portability/GFlags.h>
+#include <folly/portability/GTest.h>
+#include <folly/test/DeterministicSchedule.h>
using namespace folly;
using namespace folly::test;
}
};
- 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");
+ 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");
+ 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");
+ asm_volatile_memory();
sem.wait();
- asm volatile ("":::"memory");
+ asm_volatile_memory();
}
}
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");
+ 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);
}
-static void contendedUse(uint n, int posters, int waiters) {
+static void contendedUse(uint32_t n, int posters, int waiters) {
LifoSemImpl<std::atomic> sem;
std::vector<std::thread> threads;
BENCHMARK_SUSPEND {
for (int t = 0; t < waiters; ++t) {
threads.emplace_back([=,&sem] {
- for (uint i = t; i < n; i += waiters) {
+ for (uint32_t i = t; i < n; i += waiters) {
sem.wait();
}
});
while (!go.load()) {
std::this_thread::yield();
}
- for (uint i = t; i < n; i += posters) {
+ for (uint32_t i = t; i < n; i += posters) {
sem.post();
}
});
BENCHMARK_DRAW_LINE()
BENCHMARK_NAMED_PARAM(contendedUse, 1_to_1, 1, 1)
+BENCHMARK_NAMED_PARAM(contendedUse, 1_to_4, 1, 4)
BENCHMARK_NAMED_PARAM(contendedUse, 1_to_32, 1, 32)
+BENCHMARK_NAMED_PARAM(contendedUse, 4_to_1, 4, 1)
+BENCHMARK_NAMED_PARAM(contendedUse, 4_to_24, 4, 24)
+BENCHMARK_NAMED_PARAM(contendedUse, 8_to_100, 8, 100)
BENCHMARK_NAMED_PARAM(contendedUse, 32_to_1, 31, 1)
BENCHMARK_NAMED_PARAM(contendedUse, 16_to_16, 16, 16)
BENCHMARK_NAMED_PARAM(contendedUse, 32_to_32, 32, 32)
BENCHMARK_NAMED_PARAM(contendedUse, 32_to_1000, 32, 1000)
-// sudo nice -n -20 tao/queues/LifoSemTests --benchmark --bm_min_iters=10000000
+// sudo nice -n -20 _build/opt/folly/test/LifoSemTests
+// --benchmark --bm_min_iters=10000000 --gtest_filter=-\*
// ============================================================================
-// tao/queues/LifoSemTests.cpp relative time/iter iters/s
+// folly/test/LifoSemTests.cpp relative time/iter iters/s
// ============================================================================
-// lifo_sem_pingpong 1.91us 522.92K
-// lifo_sem_oneway 211.18ns 4.74M
-// single_thread_lifo_post 19.71ns 50.75M
-// single_thread_lifo_wait 18.84ns 53.09M
-// single_thread_lifo_postwait 39.41ns 25.37M
-// single_thread_lifo_trywait 912.10ps 1.10G
-// single_thread_posix_postwait 32.93ns 30.37M
-// single_thread_posix_trywait 10.06ns 99.36M
+// lifo_sem_pingpong 1.31us 762.40K
+// lifo_sem_oneway 193.89ns 5.16M
+// single_thread_lifo_post 15.37ns 65.08M
+// single_thread_lifo_wait 13.60ns 73.53M
+// single_thread_lifo_postwait 29.43ns 33.98M
+// single_thread_lifo_trywait 677.69ps 1.48G
+// single_thread_posix_postwait 25.03ns 39.95M
+// single_thread_posix_trywait 7.30ns 136.98M
// ----------------------------------------------------------------------------
-// contendedUse(1_to_1) 208.21ns 4.80M
-// contendedUse(1_to_32) 532.41ns 1.88M
-// contendedUse(32_to_1) 153.74ns 6.50M
-// contendedUse(16_to_16) 301.86ns 3.31M
-// contendedUse(32_to_32) 268.32ns 3.73M
-// contendedUse(32_to_1000) 966.27ns 1.03M
+// contendedUse(1_to_1) 158.22ns 6.32M
+// contendedUse(1_to_4) 574.73ns 1.74M
+// contendedUse(1_to_32) 592.94ns 1.69M
+// contendedUse(4_to_1) 118.28ns 8.45M
+// contendedUse(4_to_24) 667.62ns 1.50M
+// contendedUse(8_to_100) 701.46ns 1.43M
+// contendedUse(32_to_1) 165.06ns 6.06M
+// contendedUse(16_to_16) 238.57ns 4.19M
+// contendedUse(32_to_32) 219.82ns 4.55M
+// contendedUse(32_to_1000) 777.42ns 1.29M
// ============================================================================
int main(int argc, char ** argv) {
testing::InitGoogleTest(&argc, argv);
- google::ParseCommandLineFlags(&argc, &argv, true);
+ gflags::ParseCommandLineFlags(&argc, &argv, true);
int rv = RUN_ALL_TESTS();
folly::runBenchmarksOnFlag();
return rv;
projects / folly.git / blobdiff