mirror of https://github.com/deavmi/tasky.git
Create a new Eventy Engine instance per TaskManager instance
This commit is contained in:
parent
bc80c4aec5
commit
b72fdfe4f3
15
source/app.d
15
source/app.d
|
@ -140,14 +140,24 @@ public final class TaskManager : Thread
|
||||||
*/
|
*/
|
||||||
private Manager manager;
|
private Manager manager;
|
||||||
|
|
||||||
|
/**
|
||||||
|
* Task management
|
||||||
|
*/
|
||||||
private DList!(Task) currentTasks;
|
private DList!(Task) currentTasks;
|
||||||
private Mutex currentTasksLock;
|
private Mutex currentTasksLock;
|
||||||
|
|
||||||
|
/**
|
||||||
|
* Event-loop system
|
||||||
|
*/
|
||||||
|
private Engine eventEngine;
|
||||||
|
|
||||||
this(Manager manager)
|
this(Manager manager)
|
||||||
{
|
{
|
||||||
super(&worker);
|
super(&worker);
|
||||||
this.manager = manager;
|
this.manager = manager;
|
||||||
this.currentTasksLock = new Mutex();
|
this.currentTasksLock = new Mutex();
|
||||||
|
|
||||||
|
eventEngine = new Engine();
|
||||||
}
|
}
|
||||||
|
|
||||||
private void worker()
|
private void worker()
|
||||||
|
@ -166,6 +176,11 @@ public final class TaskManager : Thread
|
||||||
{
|
{
|
||||||
/* Dequeue the item */
|
/* Dequeue the item */
|
||||||
QueueItem tQueueItem = tQueue.dequeue();
|
QueueItem tQueueItem = tQueue.dequeue();
|
||||||
|
|
||||||
|
/* Delete the queue */
|
||||||
|
manager.removeQueue(tQueue);
|
||||||
|
|
||||||
|
/* TODO: Add dispatch here */
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
Loading…
Reference in New Issue