thread_safe_value.h

Go to the documentation of this file.

// Copyright (c) Space-ng, inc. All rights reserved.
 
#pragma once
 
#include <mutex>
#include <shared_mutex>
#include <utility>
 
namespace sol3::cpp {
 
template <typename TData>
class ThreadSafeValue {
 public:
  ThreadSafeValue() = default;
  explicit ThreadSafeValue(TData data) : data_(std::move(data)) {}
 
  // ThreadSafeValue<Foo> tv(std::in_place, arg1, arg2);
  template <typename... TArgs>
  explicit ThreadSafeValue(std::in_place_t in_place, TArgs&&... args)
      : data_(std::forward<TArgs>(args)...) {
    (void)in_place;
  }
 
  template <typename TFunction>
  auto mutate(TFunction&& cb) {
    std::unique_lock<std::shared_mutex> lock(mtx_);
    return std::forward<TFunction>(cb)(data_);
  }
 
  template <typename TFunction>
  auto access(TFunction&& cb) const {
    std::shared_lock<std::shared_mutex> lock(mtx_);
    return std::forward<TFunction>(cb)(data_);
  }
 
 private:
  mutable std::shared_mutex mtx_;
  TData data_;
};
 
}  // namespace sol3::cpp