Add AsyncioRunnable

cpp/mrc/include/mrc/coroutines/scheduler.hpp

@@ -17,21 +17,14 @@
 
 #pragma once
 
-#include "mrc/coroutines/task.hpp"
-
 #include <coroutine>
 #include <cstddef>
 #include <memory>
 #include <mutex>
 #include <string>
 
-// IWYU thinks this is needed, but it's not
-// IWYU pragma: no_include "mrc/coroutines/task_container.hpp"
-
 namespace mrc::coroutines {
 
-class TaskContainer;  // IWYU pragma: keep
-
 /**
  * @brief Scheduler base class
  *
@@ -75,9 +68,6 @@ class Scheduler : public std::enable_shared_from_this<Scheduler>
      */
     [[nodiscard]] virtual auto schedule() -> Operation;
 
-    // Enqueues a message without waiting for it. Must return void since the caller will not get the return value
-    virtual void schedule(Task<void>&& task);
-
     /**
      * Schedules any coroutine handle that is ready to be resumed.
      * @param handle The coroutine handle to schedule.
@@ -103,13 +93,6 @@ class Scheduler : public std::enable_shared_from_this<Scheduler>
   protected:
     virtual auto on_thread_start(std::size_t) -> void;
 
-    /**
-     * @brief Get the task container object
-     *
-     * @return TaskContainer&
-     */
-    TaskContainer& get_task_container() const;
-
   private:
     /**
      * @brief When co_await schedule() is called, this function will be executed by the awaiter. Each scheduler
@@ -123,9 +106,6 @@ class Scheduler : public std::enable_shared_from_this<Scheduler>
 
     mutable std::mutex m_mutex;
 
-    // Maintains the lifetime of fire-and-forget tasks scheduled with schedule(Task<void>&& task)
-    std::unique_ptr<TaskContainer> m_task_container;
-
     thread_local static Scheduler* m_thread_local_scheduler;
     thread_local static std::size_t m_thread_id;
 };

cpp/mrc/src/public/coroutines/scheduler.cpp

@@ -17,14 +17,10 @@
 
 #include "mrc/coroutines/scheduler.hpp"
 
-#include "mrc/coroutines/task_container.hpp"
-
 #include <glog/logging.h>
 
-#include <memory>
 #include <ostream>
 #include <thread>
-#include <utility>
 
 namespace mrc::coroutines {
 
@@ -39,18 +35,13 @@ std::coroutine_handle<> Scheduler::Operation::await_suspend(std::coroutine_handl
     return m_scheduler.schedule_operation(this);
 }
 
-Scheduler::Scheduler() : m_task_container(new TaskContainer(*this)) {}
+Scheduler::Scheduler() = default;
 
 auto Scheduler::schedule() -> Operation
 {
     return Operation{*this};
 }
 
-void Scheduler::schedule(Task<void>&& task)
-{
-    return m_task_container->start(std::move(task));
-}
-
 auto Scheduler::yield() -> Operation
 {
     return schedule();
@@ -77,9 +68,4 @@ auto Scheduler::on_thread_start(std::size_t thread_id) -> void
     m_thread_local_scheduler = this;
 }
 
-TaskContainer& Scheduler::get_task_container() const
-{
-    return *m_task_container;
-}
-
 }  // namespace mrc::coroutines