diff options
Diffstat (limited to 'src/demos/newt/util/TaskToolWM.java')
-rw-r--r-- | src/demos/newt/util/TaskToolWM.java | 227 |
1 files changed, 227 insertions, 0 deletions
diff --git a/src/demos/newt/util/TaskToolWM.java b/src/demos/newt/util/TaskToolWM.java new file mode 100644 index 0000000..eade4e6 --- /dev/null +++ b/src/demos/newt/util/TaskToolWM.java @@ -0,0 +1,227 @@ +/* + * Copyright (c) 2009 Sun Microsystems, Inc. All Rights Reserved. + * + * Redistribution and use in source and binary forms, with or without + * modification, are permitted provided that the following conditions are + * met: + * + * - Redistribution of source code must retain the above copyright + * notice, this list of conditions and the following disclaimer. + * + * - Redistribution in binary form must reproduce the above copyright + * notice, this list of conditions and the following disclaimer in the + * documentation and/or other materials provided with the distribution. + * + * Neither the name of Sun Microsystems, Inc. or the names of + * contributors may be used to endorse or promote products derived from + * this software without specific prior written permission. + * + * This software is provided "AS IS," without a warranty of any kind. ALL + * EXPRESS OR IMPLIED CONDITIONS, REPRESENTATIONS AND WARRANTIES, + * INCLUDING ANY IMPLIED WARRANTY OF MERCHANTABILITY, FITNESS FOR A + * PARTICULAR PURPOSE OR NON-INFRINGEMENT, ARE HEREBY EXCLUDED. SUN + * MICROSYSTEMS, INC. ("SUN") AND ITS LICENSORS SHALL NOT BE LIABLE FOR + * ANY DAMAGES SUFFERED BY LICENSEE AS A RESULT OF USING, MODIFYING OR + * DISTRIBUTING THIS SOFTWARE OR ITS DERIVATIVES. IN NO EVENT WILL SUN OR + * ITS LICENSORS BE LIABLE FOR ANY LOST REVENUE, PROFIT OR DATA, OR FOR + * DIRECT, INDIRECT, SPECIAL, CONSEQUENTIAL, INCIDENTAL OR PUNITIVE + * DAMAGES, HOWEVER CAUSED AND REGARDLESS OF THE THEORY OF LIABILITY, + * ARISING OUT OF THE USE OF OR INABILITY TO USE THIS SOFTWARE, EVEN IF + * SUN HAS BEEN ADVISED OF THE POSSIBILITY OF SUCH DAMAGES. + * + * You acknowledge that this software is not designed or intended for use + * in the design, construction, operation or maintenance of any nuclear + * facility. + */ + +package demos.newt.util; + +import java.util.*; + +import javax.media.nativewindow.*; +import com.sun.javafx.newt.*; + +public class TaskToolWM { + final static boolean externalStimuli; + final static TaskManager eventMgr; + final static Runnable eventMgrRunnable; + final static TaskManager renderMgr; + final static Runnable renderMgrRunnable; + final static Map/*Window,Runnable*/ window2Event; + final static Map/*Window,Set*/ window2Set; + + static { + System.setProperty("java.awt.headless", "true"); + + window2Event = new HashMap(); + window2Set = new HashMap(); + + externalStimuli = Boolean.getBoolean("demos.newt.util.TaskToolWM.externalStimuli"); + + eventMgr = new TaskManager("Event Manager"); + eventMgrRunnable = eventMgr.start(externalStimuli); + + renderMgr = new TaskManager("Render Manager"); + renderMgrRunnable = renderMgr.start(externalStimuli); + + /** + String osName = System.getProperty("os.name"); + if (osNameLowerCase.startsWith("mac os x") || + osNameLowerCase.startsWith("darwin")) { + TaskManagerMacOSX.registerEventRunnable(eventMgrRunnable); + TaskManagerMacOSX.registerRenderRunnable(renderMgrRunnable); + } */ + } + + private static class EventThread implements Runnable { + Window window; + + EventThread(Window w) { + window = w; + } + public void run() { + try { + // prolog - lock whatever you need + + // do it .. + if(null!=window) { + window.pumpMessages(); + } + } catch (Throwable t) { + // handle errors .. + t.printStackTrace(); + } finally { + // epilog - unlock locked stuff + } + } + } + + public static boolean registerWindowEvent(Window w) { + boolean res; + synchronized(window2Event) { + Runnable evt = (Runnable) window2Event.get(w); + if(null==evt) { + evt = new EventThread(w); + window2Event.put(w, evt); + eventMgr.addTask(evt); + res = true; + } else { + res = false; + } + } + return res; + } + + public static boolean unregisterWindowEvent(Window w) { + boolean res; + synchronized(window2Event) { + Runnable evt = (Runnable) window2Event.remove(w); + if(null!=evt) { + eventMgr.removeTask(evt); + res = true; + } else { + res = false; + } + } + return res; + } + + public static boolean isWindowEventRegistered(Window w) { + boolean res; + synchronized(window2Event) { + res = null != window2Event.get(w); + } + return res; + } + + public static void waitUntilWindowsUnregistered() { + while(window2Event.size()>0) { + eventMgr.waitOnWorker(); + } + } + + public static void waitUntilWindowUnregistered(Window w) { + while(isWindowEventRegistered(w)) { + eventMgr.waitOnWorker(); + } + } + + public static boolean addRenderTask(Window w, Runnable task) { + boolean res; + synchronized(window2Set) { + Set s = (Set) window2Set.get(w); + if(null==s) { + s = new HashSet(); + window2Set.put(w, s); + } + if(s.add(task)) { + renderMgr.addTask(task); + res = true; + } else { + res = false; + } + } + return res; + } + + public static boolean removeRenderTasks(Window w) { + boolean res; + synchronized(window2Set) { + Set s = (Set) window2Set.get(w); + if(null==s) { + res = false; + } else { + for(Iterator i=s.iterator(); i.hasNext(); ) { + Runnable task = (Runnable) i.next(); + renderMgr.removeTask(task); + i.remove(); + } + window2Set.remove(w); + res = true; + } + } + return res; + } + + public static boolean removeRenderTask(Window w, Runnable task) { + boolean res; + synchronized(window2Set) { + Set s = (Set) window2Set.get(w); + if(null==s) { + res = false; + } else { + if(s.remove(task)) { + renderMgr.removeTask(task); + if(s.size()==0) { + window2Set.remove(w); + } + res = true; + } else { + res = false; + } + } + } + return res; + } + + public static Runnable[] getRenderTasks(Window w) { + Runnable[] res=null; + synchronized(window2Set) { + Set s = (Set) window2Set.get(w); + if(null!=s) { + res = (Runnable[])s.toArray(); + } + } + return res; + } + + public static void exit(boolean systemExit) { + eventMgr.stop(); + renderMgr.stop(); + if(systemExit) { + System.exit(0); + } + } +} + + |