diff dwt/internal/Lock.d @ 0:380af2bdd8e5

Upload of whole dwt tree
author Jacob Carlborg <doob@me.com> <jacob.carlborg@gmail.com>
date Sat, 09 Aug 2008 17:00:02 +0200
parents
children d8635bb48c7c
line wrap: on
line diff
--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/dwt/internal/Lock.d	Sat Aug 09 17:00:02 2008 +0200
@@ -0,0 +1,92 @@
+/*******************************************************************************
+ * Copyright (c) 2000, 2005 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
+ *
+ * Port to the D programming language:
+ *     Frank Benoit <benoit@tionex.de>
+ *******************************************************************************/
+module dwt.internal.Lock;
+
+import tango.core.Thread;
+import tango.core.sync.Mutex;
+import tango.core.sync.Condition;
+import tango.core.Exception;
+
+import dwt.dwthelper.utils;
+
+/**
+ * Instance of this represent a recursive monitor.
+ */
+public class Lock
+{
+    int count, waitCount;
+    Thread owner;
+    Mutex mutex;
+    Condition cond;
+
+    public this ()
+    {
+        mutex = new Mutex;
+        cond = new Condition(mutex);
+    }
+
+    /**
+     * Locks the monitor and returns the lock count. If
+     * the lock is owned by another thread, wait until
+     * the lock is released.
+     *
+     * @return the lock count
+     */
+    public int lock ()
+    {
+        synchronized (mutex)
+        {
+            Thread current = Thread.getThis();
+            if (owner !is current)
+            {
+                waitCount++;
+                while (count > 0)
+                {
+                    try
+                    {
+                        cond.wait();
+                    }
+                    catch (SyncException e)
+                    {
+                    /* Wait forever, just like synchronized blocks */
+                    }
+                }
+                --waitCount;
+                owner = current;
+            }
+            return ++count;
+        }
+    }
+
+    /**
+     * Unlocks the monitor. If the current thread is not
+     * the monitor owner, do nothing.
+     */
+    public void unlock ()
+    {
+        synchronized (mutex)
+        {
+            Thread current = Thread.getThis();
+            if (owner is current)
+            {
+                if (--count is 0)
+                {
+                    owner = null;
+                    if (waitCount > 0)
+                        cond.notifyAll();
+                }
+            }
+        }
+    }
+}