/dports/devel/quantum/quantum-2.2/quantum/interface/ |
H A D | quantum_iqueue.h | 50 virtual void enqueue(ITask::Ptr task) = 0; 52 virtual bool tryEnqueue(ITask::Ptr task) = 0; 78 static ITask::Ptr getCurrentTask(); 80 static void setCurrentTask(ITask::Ptr task); 86 ITask::Ptr task); 92 static ITask::Ptr& currentTask(); 137 using QueueListAllocator = StlAllocator<ITask::Ptr>; 142 ITask::Ptr& IQueue::currentTask() in currentTask() 144 static thread_local ITask::Ptr currentTask; in currentTask() 149 ITask::Ptr IQueue::getCurrentTask() in getCurrentTask() [all …]
|
H A D | quantum_itask.h | 34 struct ITask : public ITerminate struct 36 using Ptr = std::shared_ptr<ITask>; argument 37 using WeakPtr = std::weak_ptr<ITask>; argument 57 ~ITask() = default; argument 80 using ITaskPtr = ITask::Ptr; 81 using ITaskWeakPtr = ITask::WeakPtr;
|
/dports/textproc/jalingo/jalingo-0.6.0-src/src/ja/centre/gui/concurrent/ |
H A D | TaskSequence.java | 37 private ArrayList<ITask> tasks = new ArrayList<ITask>(); 50 public TaskSequence addTask( ITask task ) { in addTask() 55 public TaskSequence addGuiTask( ITask task ) { in addGuiTask() 60 public TaskSequence addGuiTaskParallel( ITask task ) { in addGuiTaskParallel() 77 ITask task = (ITask) iterator.next(); in runAndWaint() 83 wrapGuiTask( new ITask() { in runAndWaint() 95 private static ITask wrapGuiTask( final ITask task ) { in wrapGuiTask() 96 return new ITask() { in wrapGuiTask() 114 private static ITask wrapGuiTaskParallel( final ITask task ) { 115 return new ITask() {
|
/dports/audio/lsp-plugins-lv2/lsp-plugins-1.1.31/include/core/ipc/ |
H A D | IExecutor.h | 36 static inline void change_task_state(ITask *task, ITask::task_state_t state) in change_task_state() 41 static inline void link_task(ITask *tail, ITask *link) in link_task() 47 static inline ITask *next_task(ITask *task) in next_task() 49 ITask *next = task->pNext; in next_task() 54 static inline void run_task(ITask *task) in run_task() 60 task->nState = ITask::TS_RUNNING; in run_task() 63 task->nState = ITask::TS_COMPLETED; in run_task() 81 virtual bool submit(ITask *task);
|
H A D | ITask.h | 32 class ITask: public IRunnable 45 ITask *pNext; 57 ITask(); 58 virtual ~ITask();
|
H A D | NativeExecutor.h | 38 ITask *pHead; 39 ITask *pTail; 55 virtual bool submit(ITask *task);
|
/dports/devel/quantum/quantum-2.2/quantum/ |
H A D | quantum_io_queue.h | 63 void enqueue(ITask::Ptr task) final; 65 bool tryEnqueue(ITask::Ptr task) final; 67 ITask::Ptr dequeue(std::atomic_bool& hint) final; 69 ITask::Ptr tryDequeue(std::atomic_bool& hint) final; 86 ITask::Ptr grabWorkItem(); 87 ITask::Ptr grabWorkItemFromAll(); 88 void doEnqueue(ITask::Ptr task); 89 ITask::Ptr doDequeue(std::atomic_bool& hint); 90 ITask::Ptr tryDequeueFromShared();
|
H A D | quantum_task_queue.h | 49 using TaskList = std::list<Task::Ptr, ContiguousPoolManager<ITask::Ptr>>; 67 void enqueue(ITask::Ptr task) final; 69 bool tryEnqueue(ITask::Ptr task) final; 71 ITask::Ptr dequeue(std::atomic_bool& hint) final; 73 ITask::Ptr tryDequeue(std::atomic_bool& hint) final; 130 void doEnqueue(ITask::Ptr task); 131 ITask::Ptr doDequeue(std::atomic_bool& hint,
|
/dports/devel/quantum/quantum-2.2/quantum/impl/ |
H A D | quantum_io_queue_impl.h | 92 ITask::Ptr task; in run() 190 void IoQueue::enqueue(ITask::Ptr task) in enqueue() 202 bool IoQueue::tryEnqueue(ITask::Ptr task) in tryEnqueue() 218 void IoQueue::doEnqueue(ITask::Ptr task) in doEnqueue() 269 ITask::Ptr task = _queue.front(); in doDequeue() 278 ITask::Ptr IoQueue::tryDequeueFromShared() in tryDequeueFromShared() 281 ITask::Ptr task; in tryDequeueFromShared() 381 ITask::Ptr IoQueue::grabWorkItem() in grabWorkItem() 384 ITask::Ptr task = nullptr; in grabWorkItem() 421 ITask::Ptr IoQueue::grabWorkItemFromAll() in grabWorkItemFromAll() [all …]
|
H A D | quantum_local_impl.h | 35 thread_local ITask::LocalStorage defaultStorage; in variable() 37 ITask::Ptr task = IQueue::getCurrentTask(); in variable() 38 ITask::LocalStorage& storage = task ? task->getLocalStorage() : defaultStorage; in variable() 47 ITask::Ptr task = IQueue::getCurrentTask(); in context() 48 if (!task || (task->getType() == ITask::Type::IO)) in context() 59 ITask::Ptr task = IQueue::getCurrentTask(); in taskId()
|
H A D | quantum_task_impl.h | 42 ITask::Type type, in Task() 61 ITask::Type type, in Task() 99 return (int)ITask::RetCode::NotCallable; in run() 103 return (int)ITask::RetCode::Blocked; in run() 107 return (int)ITask::RetCode::Sleeping; in run() 109 int rc = (int)ITask::RetCode::Running; in run() 118 return (int)ITask::RetCode::AlreadyResumed; in run() 134 ITask::Type Task::getType() const { return _type; } in getType() 202 ITask::LocalStorage& Task::getLocalStorage() in getLocalStorage()
|
H A D | quantum_task_queue_impl.h | 203 case (int)ITask::RetCode::NotCallable: in processTask() 206 case (int)ITask::RetCode::AlreadyResumed: in processTask() 209 case (int)ITask::RetCode::Blocked: in processTask() 212 case (int)ITask::RetCode::Sleeping: in processTask() 215 case (int)ITask::RetCode::Running: in processTask() 218 case (int)ITask::RetCode::Success: in processTask() 238 void TaskQueue::enqueue(ITask::Ptr task) in enqueue() 250 bool TaskQueue::tryEnqueue(ITask::Ptr task) in tryEnqueue() 266 void TaskQueue::doEnqueue(ITask::Ptr task) in doEnqueue() 321 ITask::Ptr task = *iter; in doDequeue() [all …]
|
H A D | quantum_io_task_impl.h | 89 return (int)ITask::RetCode::NotCallable; in run() 105 ITask::Type IoTask::getType() const in getType() 107 return ITask::Type::IO; in getType() 141 ITask::LocalStorage& IoTask::getLocalStorage() in getLocalStorage()
|
H A D | quantum_context_impl.h | 739 case ITask::Type::Continuation: in validateTaskType() 740 case ITask::Type::ErrorHandler: in validateTaskType() 747 case ITask::Type::Final: in validateTaskType() 755 case ITask::Type::Termination: in validateTaskType() 784 void Context<RET>::setTask(ITask::Ptr task) in setTask() 790 ITask::Ptr Context<RET>::getTask() const in getTask() 868 validateTaskType(ITask::Type::Continuation); in then() 913 validateTaskType(ITask::Type::Final); in finally() 924 validateTaskType(ITask::Type::Final); in finally2() 934 validateTaskType(ITask::Type::Termination); in end() [all …]
|
/dports/audio/lsp-plugins-lv2/lsp-plugins-1.1.31/src/core/ipc/ |
H A D | ITask.cpp | 29 ITask::ITask() in ITask() function in lsp::ipc::ITask 36 ITask::~ITask() in ~ITask() 40 status_t ITask::run() in run()
|
/dports/lang/zig/zig-0.9.0/lib/libc/include/any-windows-any/ |
H A D | mstask.h | 37 typedef struct ITask ITask; typedef 395 struct ITask : public IScheduledWorkItem { struct 414 ULONG (WINAPI *AddRef)(ITask *This); 415 ULONG (WINAPI *Release)(ITask *This); 417 HRESULT (WINAPI *DeleteTrigger)(ITask *This,WORD iTrigger); 425 HRESULT (WINAPI *Run)(ITask *This); 426 HRESULT (WINAPI *Terminate)(ITask *This); 441 HRESULT (WINAPI *SetFlags)(ITask *This,DWORD dwFlags); 442 HRESULT (WINAPI *GetFlags)(ITask *This,DWORD *pdwFlags); 453 HRESULT (WINAPI *SetTaskFlags)(ITask *This,DWORD dwFlags); [all …]
|
/dports/lang/zig-devel/zig-0.9.0/lib/libc/include/any-windows-any/ |
H A D | mstask.h | 37 typedef struct ITask ITask; typedef 395 struct ITask : public IScheduledWorkItem { struct 414 ULONG (WINAPI *AddRef)(ITask *This); 415 ULONG (WINAPI *Release)(ITask *This); 417 HRESULT (WINAPI *DeleteTrigger)(ITask *This,WORD iTrigger); 425 HRESULT (WINAPI *Run)(ITask *This); 426 HRESULT (WINAPI *Terminate)(ITask *This); 441 HRESULT (WINAPI *SetFlags)(ITask *This,DWORD dwFlags); 442 HRESULT (WINAPI *GetFlags)(ITask *This,DWORD *pdwFlags); 453 HRESULT (WINAPI *SetTaskFlags)(ITask *This,DWORD dwFlags); [all …]
|
/dports/audio/lsp-plugins-lv2/lsp-plugins-1.1.31/include/container/lv2/ |
H A D | executor.h | 39 ipc::ITask *task; 54 virtual bool submit(ipc::ITask *task) in submit() 62 change_task_state(task, ipc::ITask::TS_SUBMITTED); in submit() 67 change_task_state(task, ipc::ITask::TS_IDLE); in submit()
|
/dports/audio/lsp-plugins-lv2/lsp-plugins-1.1.31/src/testing/utest/core/ipc/ |
H A D | executor.cpp | 36 class TestTask: public ipc::ITask 73 ipc::ITask::task_state_t ts = tasks[i]->state(); 75 (ts == ipc::ITask::TS_SUBMITTED) || 76 (ts == ipc::ITask::TS_RUNNING)
|
/dports/devel/msbuild/msbuild-0.06/src/Shared/ |
H A D | TaskLoader.cs | 53 …internal static ITask CreateTask(LoadedType loadedType, string taskName, string taskLocation, int … in CreateTask() 67 ITask taskInstanceInOtherAppDomain = null; in CreateTask() 139 return (ITask)Activator.CreateInstance(loadedType.Type); in CreateTask() 145 …taskInstanceInOtherAppDomain = (ITask)taskAppDomain.CreateInstanceFromAndUnwrap(loadedType.Assembl… in CreateTask() 170 …taskInstanceInOtherAppDomain = (ITask)taskAppDomain.CreateInstanceAndUnwrap(loadedType.Type.GetTyp… in CreateTask()
|
/dports/devel/msbuild/msbuild-0.06/src/Build.UnitTests/BackEnd/ |
H A D | AssemblyTaskFactory_Tests.cs | 260 ITask createdTask = null; in VerifyGoodTaskInstantiation() 287 ITask createdTask = null; in VerifyMatchingTaskParametersDontLaunchTaskHost1() 318 ITask createdTask = null; in VerifyMatchingTaskParametersDontLaunchTaskHost2() 349 ITask createdTask = null; in VerifyMatchingUsingTaskParametersDontLaunchTaskHost1() 382 ITask createdTask = null; in VerifyMatchingUsingTaskParametersDontLaunchTaskHost2() 415 ITask createdTask = null; in VerifyMatchingParametersDontLaunchTaskHost() 451 ITask createdTask = null; in VerifyNonmatchingUsingTaskParametersLaunchTaskHost() 485 ITask createdTask = null; in VerifyNonmatchingTaskParametersLaunchTaskHost() 517 ITask createdTask = null; in VerifyNonmatchingParametersLaunchTaskHost() 552 ITask createdTask = null; in VerifyExplicitlyLaunchTaskHost() [all …]
|
/dports/devel/msbuild/msbuild-0.06/src/Tasks/XamlTaskFactory/ |
H A D | XamlTaskFactory.cs | 215 public ITask CreateTask(IBuildEngine taskFactoryLoggingHost) in CreateTask() 218 return (ITask)_taskAssembly.CreateInstance(fullTaskName); in CreateTask() 230 public void CleanupTask(ITask task) in CleanupTask() 285 public ITask CreateTask(IBuildEngine taskFactoryLoggingHost) 290 public void CleanupTask(ITask task)
|
/dports/math/stanmath/math-4.2.0/lib/tbb_2020.3/src/test/ |
H A D | test_task_enqueue.cpp | 172 class ITask { class 174 virtual ~ITask() {} in ~ITask() 179 class TestTask : public ITask { 190 ITask* m_pTask; 192 CarrierTask(ITask* pTask) : m_pTask(pTask) {} in CarrierTask() 201 class SpawnerTask : public ITask { 202 ITask* m_taskToSpawn; 204 SpawnerTask(ITask* job) : m_taskToSpawn(job) {} in SpawnerTask()
|
/dports/devel/tbb/oneTBB-2020.3/src/test/ |
H A D | test_task_enqueue.cpp | 172 class ITask { class 174 virtual ~ITask() {} in ~ITask() 179 class TestTask : public ITask { 190 ITask* m_pTask; 192 CarrierTask(ITask* pTask) : m_pTask(pTask) {} in CarrierTask() 201 class SpawnerTask : public ITask { 202 ITask* m_taskToSpawn; 204 SpawnerTask(ITask* job) : m_taskToSpawn(job) {} in SpawnerTask()
|
/dports/devel/taskflow/taskflow-3.2.0/3rd-party/tbb/src/test/ |
H A D | test_task_enqueue.cpp | 172 class ITask { class 174 virtual ~ITask() {} in ~ITask() 179 class TestTask : public ITask { 190 ITask* m_pTask; 192 CarrierTask(ITask* pTask) : m_pTask(pTask) {} in CarrierTask() 201 class SpawnerTask : public ITask { 202 ITask* m_taskToSpawn; 204 SpawnerTask(ITask* job) : m_taskToSpawn(job) {} in SpawnerTask()
|