task.h

Go to the documentation of this file.

 
 
#pragma once
// This header file is auto-generated!
// Do not make changes to this file or they will be overwritten.
// clang-format off
#include <cx/obj.h>
#include <cx/struct.h>
#include "basictask.h"
#include <cx/closure.h>
 
CX_C_BEGIN
 
typedef struct TaskQueue TaskQueue;
typedef struct TaskQueue_WeakRef TaskQueue_WeakRef;
typedef struct TQWorker TQWorker;
typedef struct TQWorker_WeakRef TQWorker_WeakRef;
typedef struct TaskControl TaskControl;
typedef struct Task Task;
typedef struct Task_WeakRef Task_WeakRef;
saDeclarePtr(Task);
saDeclarePtr(Task_WeakRef);
#define _sti_Task _sti_object
#define SType_Task Task*
#define STStorageType_Task Task*
#define STypeArg_Task(type, val) stgeneric(object, (ObjInst*)objInstCheckClass(Task, val))
#define STypeArgPtr_Task(type, val) (stgeneric*)objInstCheckClassPtr(Task, val)
#define STypeCheckedArg_Task(type, val)    stType(type), stArg(type, val)
#define STypeCheckedPtrArg_Task(type, val) stType(type), stArgPtr(type, val)
 
typedef struct Task_ClassIf {
    ObjIface* _implements;
    ObjIface* _parent;
    size_t _size;
 
    uint32 (*run)(_In_ void* self, _In_ TaskQueue* tq, _In_ TQWorker* worker, _Inout_ TaskControl* tcon);
    void (*runCancelled)(_In_ void* self, _In_ TaskQueue* tq, _In_ TQWorker* worker);
    bool (*cancel)(_In_ void* self);
    bool (*reset)(_In_ void* self);
    bool (*wait)(_In_ void* self, int64 timeout);
} Task_ClassIf;
extern Task_ClassIf Task_ClassIf_tmpl;
 
typedef struct Task {
    union {
        Task_ClassIf* _;
        void* _is_Task;
        void* _is_BasicTask;
        void* _is_ObjInst;
    };
    ObjClassInfo* _clsinfo;
    atomic(uintptr) _ref;
    atomic(ptr) _weakref;
 
    atomic(uint32) state;        
    void* logctx;
    string name;        
    int64 last;        
    cchain oncomplete;        
} Task;
extern ObjClassInfo Task_clsinfo;
#define Task(inst) objInstCheckClass(Task, inst)
#define TaskNone ((Task*)NULL)
 
typedef struct Task_WeakRef {
    union {
        ObjInst* _inst;
        void* _is_Task_WeakRef;
        void* _is_BasicTask_WeakRef;
        void* _is_ObjInst_WeakRef;
    };
    atomic(uintptr) _ref;
    RWLock _lock;
} Task_WeakRef;
#define Task_WeakRef(inst) objWeakRefCheckClass(Task, inst)
 
// bool ftask_setState(Task* self, uint32 newstate);
#define ftask_setState(self, newstate) BasicTask__setState(BasicTask(self), newstate)
 
#define ftaskRun(self, tq, worker, tcon) (self)->_->run(Task(self), TaskQueue(tq), TQWorker(worker), tcon)
#define ftaskRunCancelled(self, tq, worker) (self)->_->runCancelled(Task(self), TaskQueue(tq), TQWorker(worker))
#define ftaskCancel(self) (self)->_->cancel(Task(self))
// bool ftaskReset(Task* self);
#define ftaskReset(self) (self)->_->reset(Task(self))
#define ftaskWait(self, timeout) (self)->_->wait(Task(self), timeout)
 
CX_C_END