Mercurial > projects > dwt-linux
view dwt/widgets/Synchronizer.d @ 27:ffa3c27c4328
Display
author | Frank Benoit <benoit@tionex.de> |
---|---|
date | Wed, 09 Jan 2008 01:08:22 +0100 |
parents | 09f5459a5014 |
children | 8015c460f713 |
line wrap: on
line source
/******************************************************************************* * Copyright (c) 2000, 2007 IBM Corporation and others. * All rights reserved. This program and the accompanying materials * are made available under the terms of the Eclipse Public License v1.0 * which accompanies this distribution, and is available at * http://www.eclipse.org/legal/epl-v10.html * * Contributors: * IBM Corporation - initial API and implementation *******************************************************************************/ module dwt.widgets.Synchronizer; import dwt.widgets.Display; import dwt.dwthelper.Runnable; class Synchronizer{ public this (Display display) { } package void asyncExec (Runnable runnable) {} package void syncExec (Runnable runnable) {} int getMessageCount (); package Thread syncThread; bool runAsyncMessages (bool all); void releaseSynchronizer (); } /++ import dwt.*; import dwt.internal.Compatibility; /** * Instances of this class provide synchronization support * for displays. A default instance is created automatically * for each display, and this instance is sufficient for almost * all applications. * <p> * <b>IMPORTANT:</b> Typical application code <em>never</em> * needs to deal with this class. It is provided only to * allow applications which require non-standard * synchronization behavior to plug in the support they * require. <em>Subclasses which override the methods in * this class must ensure that the superclass methods are * invoked in their implementations</em> * </p> * * @see Display#setSynchronizer */ public class Synchronizer { Display display; int messageCount; RunnableLock [] messages; Object messageLock = new Object (); Thread syncThread; /** * Constructs a new instance of this class. * * @param display the display to create the synchronizer on */ public this (Display display) { this.display = display; } void addLast (RunnableLock lock) { boolean wake = false; synchronized (messageLock) { if (messages == null) messages = new RunnableLock [4]; if (messageCount == messages.length) { RunnableLock[] newMessages = new RunnableLock [messageCount + 4]; System.arraycopy (messages, 0, newMessages, 0, messageCount); messages = newMessages; } messages [messageCount++] = lock; wake = messageCount == 1; } if (wake) display.wakeThread (); } /** * Causes the <code>run()</code> method of the runnable to * be invoked by the user-interface thread at the next * reasonable opportunity. The caller of this method continues * to run in parallel, and is not notified when the * runnable has completed. * * @param runnable code to run on the user-interface thread. * * @see #syncExec */ protected void asyncExec (Runnable runnable) { if (runnable == null) { display.wake (); return; } addLast (new RunnableLock (runnable)); } int getMessageCount () { synchronized (messageLock) { return messageCount; } } void releaseSynchronizer () { display = null; messages = null; messageLock = null; syncThread = null; } RunnableLock removeFirst () { synchronized (messageLock) { if (messageCount == 0) return null; RunnableLock lock = messages [0]; System.arraycopy (messages, 1, messages, 0, --messageCount); messages [messageCount] = null; if (messageCount == 0) { if (messages.length > 64) messages = null; } return lock; } } boolean runAsyncMessages () { return runAsyncMessages (false); } boolean runAsyncMessages (boolean all) { boolean run = false; do { RunnableLock lock = removeFirst (); if (lock == null) return run; run = true; synchronized (lock) { syncThread = lock.thread; try { lock.run (); } catch (Throwable t) { lock.throwable = t; SWT.error (SWT.ERROR_FAILED_EXEC, t); } finally { syncThread = null; lock.notifyAll (); } } } while (all); return run; } /** * Causes the <code>run()</code> method of the runnable to * be invoked by the user-interface thread at the next * reasonable opportunity. The thread which calls this method * is suspended until the runnable completes. * * @param runnable code to run on the user-interface thread. * * @exception SWTException <ul> * <li>ERROR_FAILED_EXEC - if an exception occurred when executing the runnable</li> * </ul> * * @see #asyncExec */ protected void syncExec (Runnable runnable) { if (display.isValidThread ()) { if (runnable != null) runnable.run (); return; } if (runnable == null) { display.wake (); return; } RunnableLock lock = new RunnableLock (runnable); /* * Only remember the syncThread for syncExec. */ lock.thread = Thread.currentThread(); synchronized (lock) { addLast (lock); boolean interrupted = false; while (!lock.done ()) { try { lock.wait (); } catch (InterruptedException e) { interrupted = true; } } if (interrupted) { Compatibility.interrupt(); } if (lock.throwable != null) { SWT.error (SWT.ERROR_FAILED_EXEC, lock.throwable); } } } } ++/