schedulable.h

Go to the documentation of this file.

/*
 * Copyright (c) Meta Platforms, Inc. and affiliates.
 *
 * This source code is licensed under the MIT license found in the
 * LICENSE file in the root directory of this source tree.
 */
 
#pragma once
 
#include <dispenso/detail/completion_event_impl.h>
#include <dispenso/task_set.h>
 
namespace dispenso {
 
class ImmediateInvoker {
 public:
  template <typename F>
  DISPENSO_REQUIRES(OnceCallableFunc<F>)
  void schedule(F&& f) const {
    f();
  }
 
  template <typename F>
  DISPENSO_REQUIRES(OnceCallableFunc<F>)
  void schedule(F&& f, ForceQueuingTag) const {
    f();
  }
};
 
constexpr ImmediateInvoker kImmediateInvoker;
 
class NewThreadInvoker {
 public:
  template <typename F>
  DISPENSO_REQUIRES(OnceCallableFunc<F>)
  void schedule(F&& f) const {
    schedule(std::forward<F>(f), ForceQueuingTag());
  }
  template <typename F>
  DISPENSO_REQUIRES(OnceCallableFunc<F>)
  void schedule(F&& f, ForceQueuingTag) const {
    std::thread thread([f = std::move(f)]() { f(); });
    thread.detach();
  }
 
 private:
};
 
constexpr NewThreadInvoker kNewThreadInvoker;
 
} // namespace dispenso