deavmi/tasky
deavmi
/
tasky
mirror of https://github.com/deavmi/tasky.git
1
0
Fork 0
Code Issues Projects Releases Wiki Activity

Cleaned up

This commit is contained in:
Tristan B. Velloza Kildaire 2021-09-15 15:10:19 +02:00
parent ccfad5a5c8
commit 0a16c111fc
1 changed files with 1 additions and 10 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

11
source/tasky/engine.d
View File

@ -70,7 +70,7 @@ unittest
TestTask testTask = new TestTask("Hello, world, this is a test message"); TestTask testTask = new TestTask("Hello, world, this is a test message");
taskManager.submitTask(testTask); taskManager.submitTask(testTask);
} }
public final class TaskManager : Thread public final class TaskManager : Thread
@ -121,21 +121,14 @@ public final class TaskManager : Thread
/* Clean list (list of jobs to be removed) */ /* Clean list (list of jobs to be removed) */
Job[] cleanList; Job[] cleanList;
// writeln("Task: Loop begin");
foreach(Job job; jobs) foreach(Job job; jobs)
{ {
writeln("Tasky: Job process begin ", job);
/* If the job is fulfilled */ /* If the job is fulfilled */
if(job.isFulfilled()) if(job.isFulfilled())
{ {
/* Get the Event for dispatching */ /* Get the Event for dispatching */
Event dispatchEvent = job.getEventForDispatch(); Event dispatchEvent = job.getEventForDispatch();
writeln("Tasky: Job is fulfilled ", job);
/* Dispatch the event */ /* Dispatch the event */
eventEngine.push(dispatchEvent); eventEngine.push(dispatchEvent);
@ -286,8 +279,6 @@ public final class TaskManager : Thread
/* Send the payload */ /* Send the payload */
manager.getSocket().send(bEncoded); manager.getSocket().send(bEncoded);
writeln("Tasky: Sent payload");
} }
/* If unsuccessful, throw exception */ /* If unsuccessful, throw exception */
else else