001: /*
002: * $RCSfile: NotificationThread.java,v $
003: *
004: * Copyright 2005-2008 Sun Microsystems, Inc. All Rights Reserved.
005: * DO NOT ALTER OR REMOVE COPYRIGHT NOTICES OR THIS FILE HEADER.
006: *
007: * This code is free software; you can redistribute it and/or modify it
008: * under the terms of the GNU General Public License version 2 only, as
009: * published by the Free Software Foundation. Sun designates this
010: * particular file as subject to the "Classpath" exception as provided
011: * by Sun in the LICENSE file that accompanied this code.
012: *
013: * This code is distributed in the hope that it will be useful, but WITHOUT
014: * ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or
015: * FITNESS FOR A PARTICULAR PURPOSE. See the GNU General Public License
016: * version 2 for more details (a copy is included in the LICENSE file that
017: * accompanied this code).
018: *
019: * You should have received a copy of the GNU General Public License version
020: * 2 along with this work; if not, write to the Free Software Foundation,
021: * Inc., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301 USA.
022: *
023: * Please contact Sun Microsystems, Inc., 4150 Network Circle, Santa Clara,
024: * CA 95054 USA or visit www.sun.com if you need additional information or
025: * have any questions.
026: *
027: * $Revision: 1.6 $
028: * $Date: 2008/02/28 20:17:27 $
029: * $State: Exp $
030: */
031:
032: package javax.media.j3d;
033:
034: import java.util.LinkedList;
035:
036: /**
037: * The NotificationThread class is used for asynchronous error notification,
038: * such as notifying ShaderError listeners.
039: */
040: class NotificationThread extends Thread {
041: // action flag for runMonitor
042: private static final int WAIT = 0;
043: private static final int NOTIFY = 1;
044: private static final int STOP = 2;
045:
046: private volatile boolean running = true;
047: private boolean waiting = false;
048: private boolean ready = false;
049:
050: private LinkedList notificationQueue = new LinkedList();
051:
052: /**
053: * Creates a new instance of NotificationThread
054: */
055: NotificationThread(ThreadGroup t) {
056: // Only one notification thread for the entire system
057: super (t, "J3D-NotificationThread");
058: }
059:
060: /**
061: * Adds a notification message to the queue
062: */
063: synchronized void addNotification(J3dNotification n) {
064: notificationQueue.add(n);
065: runMonitor(NOTIFY);
066: }
067:
068: /**
069: * Gets the list of queued notification messages
070: */
071: private synchronized J3dNotification[] getNotifications() {
072: J3dNotification[] notifications = (J3dNotification[]) notificationQueue
073: .toArray(new J3dNotification[0]);
074: notificationQueue.clear();
075: return notifications;
076: }
077:
078: /**
079: * Processes all pending notification messages
080: */
081: private void processNotifications() {
082: J3dNotification[] notifications = getNotifications();
083:
084: for (int i = 0; i < notifications.length; i++) {
085: J3dNotification n = notifications[i];
086: switch (n.type) {
087: case J3dNotification.SHADER_ERROR:
088: n.universe
089: .notifyShaderErrorListeners((ShaderError) n.args[0]);
090: break;
091: case J3dNotification.RENDERING_ERROR:
092: VirtualUniverse
093: .notifyRenderingErrorListeners((RenderingError) n.args[0]);
094: break;
095: default:
096: System.err
097: .println("J3dNotification.processNotifications: unrecognized type = "
098: + n.type);
099: }
100: }
101: }
102:
103: // Called from MasterControlThread
104: void finish() {
105: runMonitor(STOP);
106: }
107:
108: public void run() {
109: while (running) {
110: runMonitor(WAIT);
111:
112: processNotifications();
113: }
114: // System.err.println("Notification thread finished");
115: }
116:
117: private synchronized void runMonitor(int action) {
118: switch (action) {
119: case WAIT:
120: while (running && !ready) {
121: waiting = true;
122: try {
123: wait();
124: } catch (InterruptedException e) {
125: }
126: waiting = false;
127: }
128: ready = false;
129: break;
130: case NOTIFY:
131: ready = true;
132: if (waiting) {
133: notify();
134: }
135: break;
136: case STOP:
137: running = false;
138: notify();
139: break;
140: default:
141: // Should never get here...
142: assert (false);
143: }
144: }
145:
146: }
|