|
|
@ -18,8 +18,8 @@ public enum ForgeManager implements Runnable { |
|
|
|
|
|
|
|
|
|
|
|
FORGE_MANAGER; |
|
|
|
FORGE_MANAGER; |
|
|
|
|
|
|
|
|
|
|
|
private final BlockingQueue<WorkOrder> workQueue = new DelayQueue(); |
|
|
|
private final BlockingQueue<WorkOrder> workOrders = new DelayQueue(); |
|
|
|
public static final AtomicInteger workOrder = new AtomicInteger(0); |
|
|
|
public static final AtomicInteger wordOrderCounter = new AtomicInteger(0); |
|
|
|
|
|
|
|
|
|
|
|
@Override |
|
|
|
@Override |
|
|
|
public void run() { |
|
|
|
public void run() { |
|
|
@ -28,7 +28,7 @@ public enum ForgeManager implements Runnable { |
|
|
|
|
|
|
|
|
|
|
|
try { |
|
|
|
try { |
|
|
|
|
|
|
|
|
|
|
|
WorkOrder workOrder = workQueue.take(); |
|
|
|
WorkOrder workOrder = workOrders.take(); |
|
|
|
|
|
|
|
|
|
|
|
// Fulfill workOrder
|
|
|
|
// Fulfill workOrder
|
|
|
|
|
|
|
|
|
|
|
|