Concurrency samples

winterbe · winterbe · commit ca2c72389649 · 2015-03-26T09:14:05.000+01:00
diff --git a/src/com/winterbe/java8/samples/concurrent/Threads1.java b/src/com/winterbe/java8/samples/concurrent/Threads1.java
@@ -0,0 +1,58 @@
+package com.winterbe.java8.samples.concurrent;
+
+import java.util.concurrent.TimeUnit;
+
+/**
+ * @author Benjamin Winterberg
+ */
+public class Threads1 {
+
+    public static void main(String[] args) {
+        test1();
+        test2();
+        test3();
+    }
+
+    private static void test3() {
+        Runnable runnable = () -> {
+            try {
+                System.out.println("Foo " + Thread.currentThread().getName());
+                TimeUnit.SECONDS.sleep(1);
+                System.out.println("Bar " + Thread.currentThread().getName());
+            }
+            catch (InterruptedException e) {
+                e.printStackTrace();
+            }
+        };
+
+        Thread thread = new Thread(runnable);
+        thread.start();
+    }
+
+    private static void test2() {
+        Runnable runnable = () -> {
+            try {
+                System.out.println("Foo " + Thread.currentThread().getName());
+                Thread.sleep(1000);
+                System.out.println("Bar " + Thread.currentThread().getName());
+            }
+            catch (InterruptedException e) {
+                e.printStackTrace();
+            }
+        };
+
+        Thread thread = new Thread(runnable);
+        thread.start();
+    }
+
+    private static void test1() {
+        Runnable runnable = () -> System.out.println("Hello " + Thread.currentThread().getName());
+
+        runnable.run();
+
+        Thread thread = new Thread(runnable);
+        thread.start();
+
+        System.out.println("Nachos!");
+    }
+}
