aboutsummaryrefslogtreecommitdiffstats
path: root/contrib/libs/poco/Foundation/include/Poco/ScopedLock.h
diff options
context:
space:
mode:
authorDevtools Arcadia <arcadia-devtools@yandex-team.ru>2022-02-07 18:08:42 +0300
committerDevtools Arcadia <arcadia-devtools@mous.vla.yp-c.yandex.net>2022-02-07 18:08:42 +0300
commit1110808a9d39d4b808aef724c861a2e1a38d2a69 (patch)
treee26c9fed0de5d9873cce7e00bc214573dc2195b7 /contrib/libs/poco/Foundation/include/Poco/ScopedLock.h
downloadydb-1110808a9d39d4b808aef724c861a2e1a38d2a69.tar.gz
intermediate changes
ref:cde9a383711a11544ce7e107a78147fb96cc4029
Diffstat (limited to 'contrib/libs/poco/Foundation/include/Poco/ScopedLock.h')
-rw-r--r--contrib/libs/poco/Foundation/include/Poco/ScopedLock.h121
1 files changed, 121 insertions, 0 deletions
diff --git a/contrib/libs/poco/Foundation/include/Poco/ScopedLock.h b/contrib/libs/poco/Foundation/include/Poco/ScopedLock.h
new file mode 100644
index 0000000000..483f821f5b
--- /dev/null
+++ b/contrib/libs/poco/Foundation/include/Poco/ScopedLock.h
@@ -0,0 +1,121 @@
+//
+// ScopedLock.h
+//
+// Library: Foundation
+// Package: Threading
+// Module: Mutex
+//
+// Definition of the ScopedLock template class.
+//
+// Copyright (c) 2004-2006, Applied Informatics Software Engineering GmbH.
+// and Contributors.
+//
+// SPDX-License-Identifier: BSL-1.0
+//
+
+
+#ifndef Foundation_ScopedLock_INCLUDED
+#define Foundation_ScopedLock_INCLUDED
+
+
+#include "Poco/Foundation.h"
+
+
+namespace Poco {
+
+
+template <class M>
+class ScopedLock
+ /// A class that simplifies thread synchronization
+ /// with a mutex.
+ /// The constructor accepts a Mutex (and optionally
+ /// a timeout value in milliseconds) and locks it.
+ /// The destructor unlocks the mutex.
+{
+public:
+ explicit ScopedLock(M& mtx): _mutex(mtx)
+ {
+ _mutex.lock();
+ }
+
+ ScopedLock(M& mutex, long milliseconds): _mutex(mutex)
+ {
+ _mutex.lock(milliseconds);
+ }
+
+ ~ScopedLock()
+ {
+ try
+ {
+ _mutex.unlock();
+ }
+ catch (...)
+ {
+ poco_unexpected();
+ }
+ }
+
+private:
+ M& _mutex;
+
+ ScopedLock();
+ ScopedLock(const ScopedLock&);
+ ScopedLock& operator = (const ScopedLock&);
+};
+
+
+template <class M>
+class ScopedLockWithUnlock
+ /// A class that simplifies thread synchronization
+ /// with a mutex.
+ /// The constructor accepts a Mutex (and optionally
+ /// a timeout value in milliseconds) and locks it.
+ /// The destructor unlocks the mutex.
+ /// The unlock() member function allows for manual
+ /// unlocking of the mutex.
+{
+public:
+ explicit ScopedLockWithUnlock(M& mutex): _pMutex(&mutex)
+ {
+ _pMutex->lock();
+ }
+
+ ScopedLockWithUnlock(M& mutex, long milliseconds): _pMutex(&mutex)
+ {
+ _pMutex->lock(milliseconds);
+ }
+
+ ~ScopedLockWithUnlock()
+ {
+ try
+ {
+ unlock();
+ }
+ catch (...)
+ {
+ poco_unexpected();
+ }
+ }
+
+ void unlock()
+ {
+ if (_pMutex)
+ {
+ _pMutex->unlock();
+ _pMutex = 0;
+ }
+ }
+
+private:
+ M* _pMutex;
+
+ ScopedLockWithUnlock();
+ ScopedLockWithUnlock(const ScopedLockWithUnlock&);
+ ScopedLockWithUnlock& operator = (const ScopedLockWithUnlock&);
+};
+
+
+} // namespace Poco
+
+
+#endif // Foundation_ScopedLock_INCLUDED