jdk/src/java.desktop/share/classes/sun/print/ServiceNotifier.java
changeset 25859 3317bb8137f4
parent 25140 80e863984492
child 29922 7b9c1e1532cf
--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/jdk/src/java.desktop/share/classes/sun/print/ServiceNotifier.java	Sun Aug 17 15:54:13 2014 +0100
@@ -0,0 +1,148 @@
+/*
+ * Copyright (c) 2000, 2014, Oracle and/or its affiliates. All rights reserved.
+ * DO NOT ALTER OR REMOVE COPYRIGHT NOTICES OR THIS FILE HEADER.
+ *
+ * This code is free software; you can redistribute it and/or modify it
+ * under the terms of the GNU General Public License version 2 only, as
+ * published by the Free Software Foundation.  Oracle designates this
+ * particular file as subject to the "Classpath" exception as provided
+ * by Oracle in the LICENSE file that accompanied this code.
+ *
+ * This code is distributed in the hope that it will be useful, but WITHOUT
+ * ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or
+ * FITNESS FOR A PARTICULAR PURPOSE.  See the GNU General Public License
+ * version 2 for more details (a copy is included in the LICENSE file that
+ * accompanied this code).
+ *
+ * You should have received a copy of the GNU General Public License version
+ * 2 along with this work; if not, write to the Free Software Foundation,
+ * Inc., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301 USA.
+ *
+ * Please contact Oracle, 500 Oracle Parkway, Redwood Shores, CA 94065 USA
+ * or visit www.oracle.com if you need additional information or have any
+ * questions.
+ */
+
+package sun.print;
+
+import java.util.Vector;
+
+import javax.print.PrintService;
+import javax.print.attribute.PrintServiceAttributeSet;
+import javax.print.attribute.HashPrintServiceAttributeSet;
+import javax.print.event.PrintServiceAttributeEvent;
+import javax.print.event.PrintServiceAttributeListener;
+
+/*
+ * A utility class usable by all print services for managing listeners
+ * The services create an instance and delegate the listener callback
+ * management to this class. The ServiceNotifier calls back to the service
+ * to obtain the state of the attributes and notifies the listeners of
+ * any changes.
+ */
+class ServiceNotifier extends Thread {
+
+    private PrintService service;
+    private Vector<PrintServiceAttributeListener> listeners;
+    private boolean stop = false;
+    private PrintServiceAttributeSet lastSet;
+
+    ServiceNotifier(PrintService service) {
+        super(service.getName() + " notifier");
+        this.service = service;
+        listeners = new Vector<>();
+        try {
+              setPriority(Thread.NORM_PRIORITY-1);
+              setDaemon(true);
+              start();
+        } catch (SecurityException e) {
+        }
+    }
+
+    void addListener(PrintServiceAttributeListener listener) {
+        synchronized (this) {
+            if (listener == null || listeners == null) {
+                return;
+            }
+            listeners.add(listener);
+        }
+    }
+
+    void removeListener(PrintServiceAttributeListener listener) {
+         synchronized (this) {
+            if (listener == null || listeners == null) {
+                return;
+            }
+            listeners.remove(listener);
+        }
+    }
+
+   boolean isEmpty() {
+     return (listeners == null || listeners.isEmpty());
+   }
+
+   void stopNotifier() {
+      stop = true;
+   }
+
+    /* If a service submits a job it may call this method which may prompt
+     * immediate notification of listeners.
+     */
+    void wake() {
+        try {
+            interrupt();
+        } catch (SecurityException e) {
+        }
+    }
+
+   /* A heuristic is used to calculate sleep time.
+     * 10 times the time taken to loop through all the listeners, with
+     * a minimum of 15 seconds. Ensures this won't take more than 10%
+     * of available time.
+     */
+    public void run() {
+
+       long minSleepTime = 15000;
+       long sleepTime = 2000;
+       HashPrintServiceAttributeSet attrs;
+       PrintServiceAttributeEvent attrEvent;
+       PrintServiceAttributeListener listener;
+       PrintServiceAttributeSet psa;
+
+       while (!stop) {
+           try {
+                Thread.sleep(sleepTime);
+           } catch (InterruptedException e) {
+           }
+           synchronized (this) {
+               if (listeners == null) {
+                   continue;
+               }
+               long startTime = System.currentTimeMillis();
+               if (listeners != null) {
+                    if (service instanceof AttributeUpdater) {
+                       psa =
+                          ((AttributeUpdater)service).getUpdatedAttributes();
+                    } else {
+                       psa = service.getAttributes();
+                    }
+                    if (psa != null && !psa.isEmpty()) {
+                        for (int i = 0; i < listeners.size() ; i++) {
+                            listener = listeners.elementAt(i);
+                            attrs =
+                                new HashPrintServiceAttributeSet(psa);
+                            attrEvent =
+                                new PrintServiceAttributeEvent(service, attrs);
+                            listener.attributeUpdate(attrEvent);
+                        }
+                    }
+               }
+               sleepTime = (System.currentTimeMillis()-startTime)*10;
+               if (sleepTime < minSleepTime) {
+                   sleepTime = minSleepTime;
+               }
+           }
+       }
+    }
+
+}