package pw.koj.jetstreem.core;

import java.util.concurrent.LinkedBlockingQueue;

public final class StrmQueue extends LinkedBlockingQueue {
    private static StrmQueue instance;

    private StrmQueue() {
        super();
    }

    public static synchronized StrmQueue getInstance() {
        if (instance == null) {
            instance = new StrmQueue();
        }
        return instance;
    }
}


@@ -394,11 +394,135 @@
 ;%0A    %7D%0A
+%0A    public void queueExec() %7B%0A        StrmQueueEntry entry = (StrmQueueEntry)this.poll();%0A%0A        entry.perform();%0A    %7D%0A%0A
 %7D%0A%0A

add queueExec() to StrmQueue