1 files changed, 45 insertions, 0 deletions
diff --git a/runtime/org.eclipse.etrice.runtime.java/src/org/eclipse/etrice/runtime/java/modelbase/TestSemaphore.java b/runtime/org.eclipse.etrice.runtime.java/src/org/eclipse/etrice/runtime/java/modelbase/TestSemaphore.java
new file mode 100644
index 000000000..973db66a9
--- /dev/null
+++ b/runtime/org.eclipse.etrice.runtime.java/src/org/eclipse/etrice/runtime/java/modelbase/TestSemaphore.java
@@ -0,0 +1,45 @@
+/*******************************************************************************
+ * Copyright (c) 2011 protos software gmbh (http://www.protos.de).
+ * 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:
+ * 		Henrik Rentz-Reichert (initial contribution)
+ * 
+ *******************************************************************************/
+
+package org.eclipse.etrice.runtime.java.modelbase;
+
+import java.util.Collection;
+import java.util.concurrent.Semaphore;
+
+/**
+ * @author Henrik Rentz-Reichert
+ *
+ */
+public class TestSemaphore extends Semaphore {
+
+	private static final long serialVersionUID = -2067749220670716523L;
+	
+	/**
+	 * @param permits
+	 */
+	public TestSemaphore(int permits) {
+		super(permits);
+	}
+
+	public void printWaitingThreads() {
+		System.out.println("=== begin semaphore info ===");
+		System.out.println("current thread is "+Thread.currentThread().getName());
+		Collection<Thread> threads = getQueuedThreads();
+		if (threads.isEmpty())
+			System.out.println(" no waiting threads");
+		else
+			for (Thread thread : threads) {
+				System.out.println(" "+thread.getName());
+			}
+		System.out.println("=== end semaphore info ===");
+	}
+}