IOWorker.hpp

This File On Github
Ask A Question

API: latest
module: oatpp
#include "oatpp/core/async/worker/IOWorker.hpp"

IOWorker

Naive implementation of IOWorker. Polls all I/O handles in a loop. Reschedules long-waiting handles to Timer.

namespace oatpp { namespace async { namespace worker { 
  class IOWorker : public Worker {}
}}}

Methods

Return Type Name Summary
[none] IOWorker Constructor.
void pushTasks Push list of tasks to worker.
void pushOneTask Push one task to worker.
void run Run worker.
void stop Break run loop.
void join Join all worker-threads.
void detach Detach all worker-threads.

IOWorker::IOWorker

Constructor.

IOWorker()

IOWorker::pushTasks

Push list of tasks to worker.

void pushTasks(oatpp::collection::FastQueue<CoroutineHandle>& tasks) override

IOWorker::pushOneTask

Push one task to worker.

  • @param task - CoroutineHandle.

void pushOneTask(CoroutineHandle* task) override

IOWorker::run

Run worker.

void run()

IOWorker::stop

Break run loop.

void stop() override

IOWorker::join

Join all worker-threads.

void join() override

IOWorker::detach

Detach all worker-threads.

void detach() override