mirror of https://github.com/deavmi/tasky.git
Added dispatch
This commit is contained in:
parent
b72fdfe4f3
commit
c17dbc8f2a
17
source/app.d
17
source/app.d
|
@ -90,12 +90,24 @@ unittest
|
||||||
serverThread.stopThread();
|
serverThread.stopThread();
|
||||||
|
|
||||||
//manager.start();
|
//manager.start();
|
||||||
// TaskManager tman = new TaskManager();
|
//TaskManager tman = new TaskManager();
|
||||||
}
|
}
|
||||||
|
|
||||||
public class Task
|
public class Task
|
||||||
{
|
{
|
||||||
private Event e;
|
/**
|
||||||
|
* Event-loop tag
|
||||||
|
*
|
||||||
|
* To know which signal handler should be used
|
||||||
|
*/
|
||||||
|
private Event eventType;
|
||||||
|
private Signal[] handlers;
|
||||||
|
|
||||||
|
public Event getEvent()
|
||||||
|
{
|
||||||
|
return eventType;
|
||||||
|
}
|
||||||
|
|
||||||
|
|
||||||
private byte[] dataToSend;
|
private byte[] dataToSend;
|
||||||
|
|
||||||
|
@ -181,6 +193,7 @@ public final class TaskManager : Thread
|
||||||
manager.removeQueue(tQueue);
|
manager.removeQueue(tQueue);
|
||||||
|
|
||||||
/* TODO: Add dispatch here */
|
/* TODO: Add dispatch here */
|
||||||
|
eventEngine.push(task.getEvent());
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
Loading…
Reference in New Issue