diff options
author | Devtools Arcadia <arcadia-devtools@yandex-team.ru> | 2022-02-07 18:08:42 +0300 |
---|---|---|
committer | Devtools Arcadia <arcadia-devtools@mous.vla.yp-c.yandex.net> | 2022-02-07 18:08:42 +0300 |
commit | 1110808a9d39d4b808aef724c861a2e1a38d2a69 (patch) | |
tree | e26c9fed0de5d9873cce7e00bc214573dc2195b7 /contrib/libs/poco/Foundation/include/Poco/ScopedLock.h | |
download | ydb-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.h | 121 |
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 |