/* * DO NOT ALTER OR REMOVE COPYRIGHT NOTICES OR THIS HEADER. * * Copyright 2013 Oracle and/or its affiliates. All rights reserved. * * Oracle and Java are registered trademarks of Oracle and/or its affiliates. * Other names may be trademarks of their respective owners. * * The contents of this file are subject to the terms of either the GNU * General Public License Version 2 only ("GPL") or the Common * Development and Distribution License("CDDL") (collectively, the * "License"). You may not use this file except in compliance with the * License. You can obtain a copy of the License at * http://www.netbeans.org/cddl-gplv2.html * or nbbuild/licenses/CDDL-GPL-2-CP. See the License for the * specific language governing permissions and limitations under the * License. When distributing the software, include this License Header * Notice in each file and include the License file at * nbbuild/licenses/CDDL-GPL-2-CP. Oracle designates this * particular file as subject to the "Classpath" exception as provided * by Oracle in the GPL Version 2 section of the License file that * accompanied this code. If applicable, add the following below the * License Header, with the fields enclosed by brackets [] replaced by * your own identifying information: * "Portions Copyrighted [year] [name of copyright owner]" * * If you wish your version of this file to be governed by only the CDDL * or only the GPL Version 2, indicate your decision by adding * "[Contributor] elects to include this software in this distribution * under the [CDDL or GPL Version 2] license." If you do not indicate a * single choice of license, a recipient has the option to distribute * your version of this file under either the CDDL, the GPL Version 2 or * to extend the choice of license to its licensees as provided above. * However, if you add GPL Version 2 code and therefore, elected the GPL * Version 2 license, then the option applies only if the new code is * made subject to such option by the copyright holder. * * Contributor(s): * * Portions Copyrighted 2013 Sun Microsystems, Inc. */ package org.netbeans; import java.lang.reflect.InvocationTargetException; import java.util.ArrayDeque; import java.util.logging.Level; import java.util.logging.Logger; import org.openide.util.Lookup; /** * handle running things on the main thread * @author astephens */ public abstract class MainThreadRunner { private static final Logger LOG = Logger.getLogger(MainThreadRunner.class.getName()); static boolean programTerminated = false; protected boolean isProgramTerminated(){ return programTerminated; } static MainThreadRunner deamon; static void runDeamon() throws InterruptedException{ deamon = Lookup.getDefault().lookup(MainThreadRunner.class); if (deamon == null) deamon = new DummyDeamon(); deamon.runEventLoop(); } public static void invokeAndWait(final Runnable doRun) throws InterruptedException, InvocationTargetException{ deamon.doInvokeAndWait(doRun); } public static void invokeLater(Runnable doRun){ deamon.doInvokeLater(doRun); } protected abstract void runEventLoop() throws InterruptedException; protected abstract void doInvokeAndWait(final Runnable doRun) throws InterruptedException, InvocationTargetException; protected abstract void doInvokeLater(Runnable doRun); private static class DummyDeamon extends MainThreadRunner { ArrayDeque runnables = new ArrayDeque(10); final Object syncLock = new Object(); DummyDeamon() { } @Override protected void runEventLoop() throws InterruptedException { while (!isProgramTerminated()){ RunnableToken token; synchronized(syncLock){ if (runnables.size() < 1){ try{ syncLock.wait(); // wait for more... } catch (InterruptedException ie){ if (isProgramTerminated()) return; } } token = runnables.poll(); } if (token == null) continue; try{ assert token.runnable != null; token.runnable.run(); } catch (Throwable t){ if (t instanceof InterruptedException && isProgramTerminated()) return; LOG.log(Level.SEVERE, "Uncaught exception", t); } finally{ if (token.lock != null){ synchronized(token.lock){ token.lock.ran = true; token.lock.notifyAll(); } } } } } @Override protected void doInvokeAndWait(Runnable doRun) throws InterruptedException, InvocationTargetException { final TokenLock lock = new TokenLock(); RunnableToken token = new RunnableToken(doRun, lock); synchronized(syncLock){ runnables.add(token); } synchronized(token.lock){ if (!token.lock.ran){ token.lock.wait(); } } } @Override protected void doInvokeLater(Runnable doRun) { RunnableToken token = new RunnableToken(doRun, null); synchronized(syncLock){ runnables.add(token); } } private static class RunnableToken{ final Runnable runnable; final TokenLock lock; public RunnableToken(Runnable runnable, TokenLock lock) { this.runnable = runnable; this.lock = lock; } } private static class TokenLock{ boolean ran = false; } } }