Lines Matching refs:quit
677 std::unique_ptr<std::thread> CopyTask(std::atomic<bool>* quit, void* in_base,
681 new std::thread([quit, in_base, in_size, out_base, out_size]() {
693 while (!std::atomic_load_explicit(quit, std::memory_order_relaxed)) {
712 std::atomic<bool> quit(false);
714 &quit, out_mmap.mmap(), out_mmap.size, in_mmap.mmap(), in_mmap.size);
726 std::atomic_store_explicit(&quit, true, std::memory_order_relaxed);
739 std::atomic<bool> quit(false);
741 &quit, out_mmap.mmap(), out_mmap.size, in_mmap.mmap(), in_mmap.size);
766 std::atomic_store_explicit(&quit, true, std::memory_order_relaxed);
779 std::atomic<bool> quit(false);
781 &quit, out_mmap.mmap(), out_mmap.size, in_mmap.mmap(), in_mmap.size);
803 std::atomic_store_explicit(&quit, true, std::memory_order_relaxed);
808 std::unique_ptr<std::thread> CheckFillTask(std::atomic<bool>* quit,
811 new std::thread([quit, in_base, in_size]() {
820 while (!std::atomic_load_explicit(quit, std::memory_order_relaxed)) {
842 std::atomic<bool> quit(false);
844 CheckFillTask<Ring>(&quit, out_mmap.mmap(), out_mmap.size);
852 std::atomic_store_explicit(&quit, true, std::memory_order_relaxed);