taskqueue.h

#pragma once
 
#include <cx/closure/closure.h>
#include <cx/cx.h>
#include <cx/log/log.h>
#include <cx/taskqueue/queue/tqcomplex.h>
#include <cx/taskqueue/queue/tqueue.h>
#include <cx/taskqueue/requires/taskrequiresgate.h>
#include <cx/taskqueue/resource/trfifo.h>
#include <cx/taskqueue/resource/trlifo.h>
#include <cx/taskqueue/resource/trmutex.h>
#include <cx/taskqueue/task/mptask.h>
#include <cx/taskqueue/worker/tqworker.h>
 
CX_C_BEGIN
 
 
 
void tqPresetSingle(_Out_ TaskQueueConfig* tqconfig);
 
void tqPresetMinimal(_Out_ TaskQueueConfig* tqconfig);
 
void tqPresetBalanced(_Out_ TaskQueueConfig* tqconfig);
 
void tqPresetHeavy(_Out_ TaskQueueConfig* tqconfig);
 
void tqPresetManual(_Out_ TaskQueueConfig* tqconfig);
 
void tqEnableMonitor(_Inout_ TaskQueueConfig* tqconfig);
 
 
 
_Ret_opt_valid_ _Check_return_ TaskQueue*
tqCreate(_In_ strref name, _In_ const TaskQueueConfig* tqconfig);
 
#define tqStart taskqueueStart
 
#define tqTick taskqueueTick
 
#define tqShutdown(tq, wait) taskqueueStop(tq, wait)
 
#define tqRelease(ptq) objRelease(ptq)
 
 
 
#define tqAdd(tq, task) taskqueueAdd(tq, task)
 
#define tqRun(tq, ptask)          \
    do {                          \
        taskqueueAdd(tq, *ptask); \
        objRelease(ptask);        \
    } while (0)
 
_meta_inline bool _tqSchedule(_Inout_ TaskQueue* tq, _In_ ComplexTask* task, int64 delay)
{
    ComplexTaskQueue* ctq = objDynCast(ComplexTaskQueue, tq);
    if (!ctq)
        return false;
    return ctaskqueueSchedule(ctq, task, delay);
}
#define tqSchedule(tq, task, delay) _tqSchedule(tq, ComplexTask(task), delay)
 
_meta_inline bool _tqDefer(_Inout_ TaskQueue* tq, _In_ ComplexTask* task)
{
    ComplexTaskQueue* ctq = objDynCast(ComplexTaskQueue, tq);
    if (!ctq)
        return false;
    return ctaskqueueDefer(ctq, task);
}
#define tqDefer(tq, task) _tqDefer(tq, ComplexTask(task))
 
bool tqCall(_Inout_ TaskQueue* tq, _In_ closure cls);
 
int32 tqWorkers(_In_ TaskQueue* tq);
 
 
 
_meta_inline uint32 _btaskState(BasicTask* bt)
{
    return atomicLoad(uint32, &bt->state, Acquire) & TASK_State_Mask;
}
#define btaskState(task) _btaskState(BasicTask(task))
#define taskState(task)  _btaskState(BasicTask(task))
 
_meta_inline bool _btaskIsRunning(BasicTask* bt)
{
    return _btaskState(bt) == TASK_Running;
}
#define btaskIsRunning(task) _btaskIsRunning(BasicTask(task))
#define taskIsRunning(task)  _btaskIsRunning(BasicTask(task))
 
_meta_inline bool _btaskIsPending(BasicTask* bt)
{
    uint32 state = _btaskState(bt);
    return state == TASK_Waiting || state == TASK_Deferred || state == TASK_Scheduled;
}
#define btaskIsPending(task) _btaskIsPending(BasicTask(task))
#define taskIsPending(task)  _btaskIsPending(BasicTask(task))
 
_meta_inline bool _btaskIsIdle(BasicTask* bt)
{
    uint32 state = _btaskState(bt);
    return state == TASK_Created || state == TASK_Waiting || state == TASK_Deferred ||
        state == TASK_Scheduled;
}
#define btaskIsIdle(task) _btaskIsIdle(BasicTask(task))
#define taskIsIdle(task)  _btaskIsIdle(BasicTask(task))
 
_meta_inline bool _btaskIsComplete(BasicTask* bt)
{
    uint32 state = _btaskState(bt);
    return state == TASK_Succeeded || state == TASK_Failed;
}
#define btaskIsComplete(task) _btaskIsComplete(BasicTask(task))
#define taskIsComplete(task)  _btaskIsComplete(BasicTask(task))
 
_meta_inline bool _btaskSucceeded(BasicTask* bt)
{
    return _btaskState(bt) == TASK_Succeeded;
}
#define btaskSucceeded(task) _btaskSucceeded(BasicTask(task))
#define taskSucceeded(task)  _btaskSucceeded(BasicTask(task))
 
_meta_inline bool _btaskFailed(BasicTask* bt)
{
    return _btaskState(bt) == TASK_Failed;
}
#define btaskFailed(task) _btaskFailed(BasicTask(task))
#define taskFailed(task)  _btaskFailed(BasicTask(task))
 
_meta_inline bool _btaskCancelled(BasicTask* bt)
{
    return atomicLoad(uint32, &bt->state, Acquire) & TASK_Cancelled;
}
#define btaskCancelled(task) _btaskCancelled(BasicTask(task))
#define taskCancelled(task)  _btaskCancelled(BasicTask(task))
 
#define taskCancel(task) btaskCancel(task)
 
#define taskWait(task, timeout) ftaskWait(task, timeout)
 
 
CX_C_END