runInThreadsAndWait(nproducers,
[&](size_t /* k */) {
for (size_t i = 0; i < writes / nproducers; ++i) {
- this_thread::sleep_for(chrono::milliseconds(1));
+ this_thread::sleep_for(
+ std::chrono::milliseconds(1));
efd_write(1);
}
});
runInThreadsAndWait(nproducers,
[&](size_t /* k */) {
for (size_t i = 0; i < writes / nproducers; ++i) {
- this_thread::sleep_for(chrono::milliseconds(1));
+ this_thread::sleep_for(
+ std::chrono::milliseconds(1));
queue.blockingWrite(nullptr);
efd_write(1);
--writesRemaining;