X-Git-Url: https://gerrit.simantics.org/r/gitweb?a=blobdiff_plain;f=bundles%2Forg.simantics.utils.thread%2Fsrc%2Forg%2Fsimantics%2Futils%2Fthreads%2Ftest%2FTest.java;h=aa8e2cfb6733bd6e4677b839d12f9d8f8879ed92;hb=refs%2Fchanges%2F38%2F238%2F2;hp=900b65171afb75a62839318ed9b18691a9053168;hpb=969bd23cab98a79ca9101af33334000879fb60c5;p=simantics%2Fplatform.git

diff --git a/bundles/org.simantics.utils.thread/src/org/simantics/utils/threads/test/Test.java b/bundles/org.simantics.utils.thread/src/org/simantics/utils/threads/test/Test.java
index 900b65171..aa8e2cfb6 100644
--- a/bundles/org.simantics.utils.thread/src/org/simantics/utils/threads/test/Test.java
+++ b/bundles/org.simantics.utils.thread/src/org/simantics/utils/threads/test/Test.java
@@ -1,76 +1,76 @@
-/*******************************************************************************
- * Copyright (c) 2007, 2010 Association for Decentralized Information Management
- * in Industry THTH ry.
- * 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:
- *     VTT Technical Research Centre of Finland - initial API and implementation
- *******************************************************************************/
-/*
- *
- * @author Toni Kalajainen
- */
-package org.simantics.utils.threads.test;
-
-import java.util.Random;
-
-import org.simantics.utils.threads.ThreadUtils;
-import org.simantics.utils.threads.WorkerThread;
-
-
-public class Test {
-
-	/**
-	 * @param args
-	 */
-	public static void main(String[] args) {
-		final WorkerThread list[] = new WorkerThread[10];
-		for (int i =0; i<list.length; i++)
-			list[i] = new WorkerThread();
-		
-		for (WorkerThread t : list)
-			t.start();
-		
-		final Random r = new Random();
-		
-		ExampleObject obj = new ExampleObject();
-		
-		ExampleListener l = new ExampleListener() {
-			@Override
-			public void onMessage(ExampleObject sender, String msg) {
-				try {
-					Thread.sleep(1000);
-				} catch (InterruptedException e) {}
-				System.out.println(Thread.currentThread()+": "+msg);
-				ThreadUtils.syncExec(
-						list[r.nextInt(list.length)],
-						new Runnable() {
-							@Override
-							public void run() {
-								try {
-									Thread.sleep(1000);
-								} catch (InterruptedException e) {}
-								System.out.println("blaa");
-								try {
-									Thread.sleep(1000);
-								} catch (InterruptedException e) {}
-							}});
-				try {
-					Thread.sleep(1000);
-				} catch (InterruptedException e) {}
-			}};
-		
-		for (WorkerThread t : list)						
-			obj.addListener(t, l);
-		
-		obj.fireMessage("Test");
-		System.out.println("jeps");
-
-		for (WorkerThread t : list)
-			t.stopDispatchingEvents(true);
-	}
-
-}
+/*******************************************************************************
+ * Copyright (c) 2007, 2010 Association for Decentralized Information Management
+ * in Industry THTH ry.
+ * 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:
+ *     VTT Technical Research Centre of Finland - initial API and implementation
+ *******************************************************************************/
+/*
+ *
+ * @author Toni Kalajainen
+ */
+package org.simantics.utils.threads.test;
+
+import java.util.Random;
+
+import org.simantics.utils.threads.ThreadUtils;
+import org.simantics.utils.threads.WorkerThread;
+
+
+public class Test {
+
+	/**
+	 * @param args
+	 */
+	public static void main(String[] args) {
+		final WorkerThread list[] = new WorkerThread[10];
+		for (int i =0; i<list.length; i++)
+			list[i] = new WorkerThread();
+		
+		for (WorkerThread t : list)
+			t.start();
+		
+		final Random r = new Random();
+		
+		ExampleObject obj = new ExampleObject();
+		
+		ExampleListener l = new ExampleListener() {
+			@Override
+			public void onMessage(ExampleObject sender, String msg) {
+				try {
+					Thread.sleep(1000);
+				} catch (InterruptedException e) {}
+				System.out.println(Thread.currentThread()+": "+msg);
+				ThreadUtils.syncExec(
+						list[r.nextInt(list.length)],
+						new Runnable() {
+							@Override
+							public void run() {
+								try {
+									Thread.sleep(1000);
+								} catch (InterruptedException e) {}
+								System.out.println("blaa");
+								try {
+									Thread.sleep(1000);
+								} catch (InterruptedException e) {}
+							}});
+				try {
+					Thread.sleep(1000);
+				} catch (InterruptedException e) {}
+			}};
+		
+		for (WorkerThread t : list)						
+			obj.addListener(t, l);
+		
+		obj.fireMessage("Test");
+		System.out.println("jeps");
+
+		for (WorkerThread t : list)
+			t.stopDispatchingEvents(true);
+	}
+
+}