/*
- * 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.
*/
#include <folly/LifoSem.h>
-#include <folly/test/DeterministicSchedule.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/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;
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 folly/test/LifoSemTests --benchmark --bm_min_iters=10000000
+// sudo nice -n -20 _build/opt/folly/test/LifoSemTests
+// --benchmark --bm_min_iters=10000000 --gtest_filter=-\*
// ============================================================================
// folly/test/LifoSemTests.cpp relative time/iter iters/s
// ============================================================================
-// lifo_sem_pingpong 396.84ns 2.52M
-// lifo_sem_oneway 88.52ns 11.30M
-// single_thread_lifo_post 14.78ns 67.67M
-// single_thread_lifo_wait 13.53ns 73.90M
-// single_thread_lifo_postwait 28.91ns 34.59M
-// single_thread_lifo_trywait 670.13ps 1.49G
-// single_thread_posix_postwait 24.12ns 41.46M
-// single_thread_posix_trywait 6.76ns 147.88M
+// 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) 143.60ns 6.96M
-// contendedUse(1_to_32) 244.06ns 4.10M
-// contendedUse(32_to_1) 131.99ns 7.58M
-// contendedUse(16_to_16) 210.64ns 4.75M
-// contendedUse(32_to_32) 222.91ns 4.49M
-// contendedUse(32_to_1000) 453.39ns 2.21M
+// 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) {
projects / folly.git / blobdiff