glax/Tranga
2
0
Fork 0
Code

TaskCheckerThread new logic

Browse Source
This commit is contained in:
glax 2023-05-21 01:58:24 +02:00
parent 9d0fc18051
commit 554f6b4acc
1 changed files with 4 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
Tranga/TaskManager.cs
View File

@ -66,13 +66,11 @@ public class TaskManager
//Check if previous tasks have finished and execute new tasks //Check if previous tasks have finished and execute new tasks
foreach (KeyValuePair<Connector, List<TrangaTask>> connectorTaskQueue in tasksToExecute) foreach (KeyValuePair<Connector, List<TrangaTask>> connectorTaskQueue in tasksToExecute)
{ {
connectorTaskQueue.Value.RemoveAll(task => task.state == TrangaTask.ExecutionState.Waiting); if(connectorTaskQueue.Value.RemoveAll(task => task.state == TrangaTask.ExecutionState.Waiting) > 0)
if (connectorTaskQueue.Value.Count > 0 && connectorTaskQueue.Value.All(task =>
task.state is TrangaTask.ExecutionState.Running or TrangaTask.ExecutionState.Enqueued))
{
ExecuteTaskNow(connectorTaskQueue.Value.First());
ExportData(Directory.GetCurrentDirectory()); ExportData(Directory.GetCurrentDirectory());
}
if (connectorTaskQueue.Value.Count > 0 && connectorTaskQueue.Value.All(task => task.state is TrangaTask.ExecutionState.Enqueued))
ExecuteTaskNow(connectorTaskQueue.Value.First());
} }
//Check if task should be executed //Check if task should be executed