Home
last modified time | relevance | path

Searched refs:ITask (Results 1 – 25 of 181) sorted by relevance

12345678

/dports/devel/quantum/quantum-2.2/quantum/interface/
H A Dquantum_iqueue.h50 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 Dquantum_itask.h34 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 DTaskSequence.java37 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 DIExecutor.h36 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 DITask.h32 class ITask: public IRunnable
45 ITask *pNext;
57 ITask();
58 virtual ~ITask();
H A DNativeExecutor.h38 ITask *pHead;
39 ITask *pTail;
55 virtual bool submit(ITask *task);
/dports/devel/quantum/quantum-2.2/quantum/
H A Dquantum_io_queue.h63 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 Dquantum_task_queue.h49 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 Dquantum_io_queue_impl.h92 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 Dquantum_local_impl.h35 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 Dquantum_task_impl.h42 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 Dquantum_task_queue_impl.h203 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 Dquantum_io_task_impl.h89 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 Dquantum_context_impl.h739 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 DITask.cpp29 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 Dmstask.h37 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 Dmstask.h37 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 Dexecutor.h39 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 Dexecutor.cpp36 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 DTaskLoader.cs53 …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 DAssemblyTaskFactory_Tests.cs260 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 DXamlTaskFactory.cs215 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 Dtest_task_enqueue.cpp172 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 Dtest_task_enqueue.cpp172 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 Dtest_task_enqueue.cpp172 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()

12345678