join方法的使用

bysocket · bysocket · commit 2bd5241baa78 · 2016-03-04T21:43:57.000+08:00
diff --git a/src/org/javacore/thread/join/DSLoader.java b/src/org/javacore/thread/join/DSLoader.java
@@ -0,0 +1,19 @@
+package org.javacore.thread.join;
+
+import java.util.concurrent.TimeUnit;
+
+/**
+ * Created by bysocket on 16/3/3.
+ */
+public class DSLoader implements Runnable {
+    @Override
+    public void run() {
+        System.out.println("begining the DSLoader");
+        try {
+            TimeUnit.SECONDS.sleep(4);
+        } catch (InterruptedException e) {
+            e.printStackTrace();
+        }
+        System.out.println("DSLoader has finished");
+    }
+}
diff --git a/src/org/javacore/thread/join/JoinTest.java b/src/org/javacore/thread/join/JoinTest.java
@@ -0,0 +1,20 @@
+package org.javacore.thread.join;
+
+/**
+ * Created by bysocket on 16/3/3.
+ */
+public class JoinTest {
+    public static void main(String[] args) throws InterruptedException {
+        Thread t1 = new Thread(new DSLoader());
+        Thread t2 = new Thread(new NetLoader());
+
+        t1.start();
+        t2.start();
+
+        //可以注释其中一个加深理解
+        t1.join();
+        t2.join();
+
+        System.out.println("ending all");
+    }
+}
diff --git a/src/org/javacore/thread/join/NetLoader.java b/src/org/javacore/thread/join/NetLoader.java
@@ -0,0 +1,19 @@
+package org.javacore.thread.join;
+
+import java.util.concurrent.TimeUnit;
+
+/**
+ * Created by bysocket on 16/3/3.
+ */
+public class NetLoader implements Runnable {
+    @Override
+    public void run() {
+        System.out.println("begining the NetLoader");
+        try {
+            TimeUnit.SECONDS.sleep(6);
+        } catch (InterruptedException e) {
+            e.printStackTrace();
+        }
+        System.out.println("NetLoader has finished");
+    }
+}
