SpinlockProtected.h 2.0 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273747576777879808182838485868788
  1. /*
  2. * Copyright (c) 2021, the SerenityOS developers.
  3. *
  4. * SPDX-License-Identifier: BSD-2-Clause
  5. */
  6. #pragma once
  7. #include <Kernel/Locking/Spinlock.h>
  8. namespace Kernel {
  9. template<typename T>
  10. class SpinlockProtected {
  11. AK_MAKE_NONCOPYABLE(SpinlockProtected);
  12. AK_MAKE_NONMOVABLE(SpinlockProtected);
  13. private:
  14. template<typename U>
  15. class Locked {
  16. AK_MAKE_NONCOPYABLE(Locked);
  17. AK_MAKE_NONMOVABLE(Locked);
  18. public:
  19. Locked(U& value, RecursiveSpinlock& spinlock)
  20. : m_value(value)
  21. , m_locker(spinlock)
  22. {
  23. }
  24. ALWAYS_INLINE U const* operator->() const { return &m_value; }
  25. ALWAYS_INLINE U const& operator*() const { return m_value; }
  26. ALWAYS_INLINE U* operator->() { return &m_value; }
  27. ALWAYS_INLINE U& operator*() { return m_value; }
  28. ALWAYS_INLINE U const& get() const { return m_value; }
  29. ALWAYS_INLINE U& get() { return m_value; }
  30. private:
  31. U& m_value;
  32. SpinlockLocker<RecursiveSpinlock> m_locker;
  33. };
  34. auto lock_const() const { return Locked<T const>(m_value, m_spinlock); }
  35. auto lock_mutable() { return Locked<T>(m_value, m_spinlock); }
  36. public:
  37. SpinlockProtected() = default;
  38. template<typename Callback>
  39. decltype(auto) with(Callback callback) const
  40. {
  41. auto lock = lock_const();
  42. return callback(*lock);
  43. }
  44. template<typename Callback>
  45. decltype(auto) with(Callback callback)
  46. {
  47. auto lock = lock_mutable();
  48. return callback(*lock);
  49. }
  50. template<typename Callback>
  51. void for_each_const(Callback callback) const
  52. {
  53. with([&](const auto& value) {
  54. for (auto& item : value)
  55. callback(item);
  56. });
  57. }
  58. template<typename Callback>
  59. void for_each(Callback callback)
  60. {
  61. with([&](auto& value) {
  62. for (auto& item : value)
  63. callback(item);
  64. });
  65. }
  66. private:
  67. T m_value;
  68. RecursiveSpinlock mutable m_spinlock;
  69. };
  70. }