1 package org.simantics.modeling.ui.diagramEditor;
3 import gnu.trove.map.hash.TObjectLongHashMap;
5 import java.util.ArrayDeque;
7 import org.eclipse.swt.widgets.Display;
10 public class DisposingPolicy {
12 public static final boolean DEBUG = false;
14 public static final int MAX_QUEUE_LENGTH = 8;
15 public static final long DISPOSE_TIME = 30000L; // ms
16 public static final long MIN_DELAY = 200L; // ms
18 private ArrayDeque<Runnable> disposerQueue = new ArrayDeque<Runnable>(MAX_QUEUE_LENGTH);
19 private TObjectLongHashMap<Runnable> disposeTime =
20 new TObjectLongHashMap<Runnable>(MAX_QUEUE_LENGTH);
21 private Runnable currentlyScheduled = null;
23 private Runnable disposeOne = new Runnable() {
26 if(!disposerQueue.isEmpty()) {
27 Runnable runnable = disposerQueue.removeFirst();
28 disposeTime.remove(runnable);
29 currentlyScheduled = null;
32 System.out.println("Executed disposer " + runnable);
33 if(!disposerQueue.isEmpty())
39 private void scheduleDispose() {
40 currentlyScheduled = disposerQueue.peekFirst();
41 long delay = Math.max(
42 disposeTime.get(currentlyScheduled) - System.currentTimeMillis(),
44 Display.getCurrent().timerExec((int)delay, disposeOne);
46 System.out.println("Scheduled disposer " + currentlyScheduled + " in " + delay + " ms");
50 * Runs the disposer either after DISPOSE_TIME or when there are
51 * more than MAX_QUEUE_LENGTH disposers active and this is first
52 * of them (by activation order). This method must be called from
55 public void addDisposer(Runnable disposer) {
57 System.out.println("Added disposer " + disposer);
58 if(disposeTime.contains(disposer))
60 if(disposerQueue.size() >= MAX_QUEUE_LENGTH)
62 disposerQueue.addLast(disposer);
63 disposeTime.put(disposer, System.currentTimeMillis()+DISPOSE_TIME);
64 if(disposerQueue.size() == 1)
69 * Cancels a disposer added before. This method must be called from
72 public void removeDisposer(Runnable disposer) {
74 System.out.println("Removed disposer " + disposer);
75 disposerQueue.remove(disposer);
76 disposeTime.remove(disposer);
77 if(disposer == currentlyScheduled) {
78 currentlyScheduled = null;
79 if(!disposerQueue.isEmpty())