summaryrefslogtreecommitdiffstats
path: root/src/rocksdb/util/thread_guard.h
diff options
context:
space:
mode:
authorDaniel Baumann <daniel.baumann@progress-linux.org>2024-04-21 11:54:28 +0000
committerDaniel Baumann <daniel.baumann@progress-linux.org>2024-04-21 11:54:28 +0000
commite6918187568dbd01842d8d1d2c808ce16a894239 (patch)
tree64f88b554b444a49f656b6c656111a145cbbaa28 /src/rocksdb/util/thread_guard.h
parentInitial commit. (diff)
downloadceph-e6918187568dbd01842d8d1d2c808ce16a894239.tar.xz
ceph-e6918187568dbd01842d8d1d2c808ce16a894239.zip
Adding upstream version 18.2.2.upstream/18.2.2
Signed-off-by: Daniel Baumann <daniel.baumann@progress-linux.org>
Diffstat (limited to 'src/rocksdb/util/thread_guard.h')
-rw-r--r--src/rocksdb/util/thread_guard.h41
1 files changed, 41 insertions, 0 deletions
diff --git a/src/rocksdb/util/thread_guard.h b/src/rocksdb/util/thread_guard.h
new file mode 100644
index 000000000..b2bb06a1b
--- /dev/null
+++ b/src/rocksdb/util/thread_guard.h
@@ -0,0 +1,41 @@
+// Copyright (c) 2011-present, Facebook, Inc. All rights reserved.
+// This source code is licensed under both the GPLv2 (found in the
+// COPYING file in the root directory) and Apache 2.0 License
+// (found in the LICENSE.Apache file in the root directory).
+
+#pragma once
+
+#include "port/port.h"
+#include "rocksdb/rocksdb_namespace.h"
+
+namespace ROCKSDB_NAMESPACE {
+
+// Resource management object for threads that joins the thread upon
+// destruction. Has unique ownership of the thread object, so copying it is not
+// allowed, while moving it transfers ownership.
+class ThreadGuard {
+ public:
+ ThreadGuard() = default;
+
+ explicit ThreadGuard(port::Thread&& thread) : thread_(std::move(thread)) {}
+
+ ThreadGuard(const ThreadGuard&) = delete;
+ ThreadGuard& operator=(const ThreadGuard&) = delete;
+
+ ThreadGuard(ThreadGuard&&) noexcept = default;
+ ThreadGuard& operator=(ThreadGuard&&) noexcept = default;
+
+ ~ThreadGuard() {
+ if (thread_.joinable()) {
+ thread_.join();
+ }
+ }
+
+ const port::Thread& GetThread() const { return thread_; }
+ port::Thread& GetThread() { return thread_; }
+
+ private:
+ port::Thread thread_;
+};
+
+} // namespace ROCKSDB_NAMESPACE