线程信息打印案例

Author: BYSocket

src/org/javacore/thread/ThreadInfo.java

@@ -0,0 +1,82 @@
+package org.javacore.thread;
+
+
+import java.io.FileWriter;
+import java.io.IOException;
+import java.io.PrintWriter;
+
+/**
+ * Created by bysocket on 16/2/24.
+ */
+public class ThreadInfo {
+    public static void main(String[] args) {
+        Thread threads[] = new Thread[10];
+        Thread.State status[] = new Thread.State[10];
+        for (int i = 0; i < 10; i++) {
+            threads[i] = new Thread(new Calculator(i));
+            if ((i % 2) == 0) {
+                threads[i].setPriority(Thread.MAX_PRIORITY);
+            } else {
+                threads[i].setPriority(Thread.MIN_PRIORITY);
+            }
+//            threads[i].setName("");
+        }
+
+        try {
+            // 将线程的信息写入log文件
+            FileWriter fw = new FileWriter(".\\log.txt");
+            PrintWriter pw = new PrintWriter(fw);
+
+            for (int i = 0; i <10 ;i++) {
+                pw.println("Main: Status of Thread " + i + " : "
+                        + threads[i].getState());
+                status[i] = threads[i].getState();
+            }
+
+            // 启动线程
+            for (int i = 0; i < 10 ;i++)
+                threads[i].start();
+
+            boolean finish = false;
+            while (!finish) {
+                for(int i = 0;i < 10 ;i++) {
+                    if (threads[i].getState() != status[i]) {
+                        writeThreadInfo(pw,threads[i],status[i]);
+                        status[i] = threads[i].getState();
+                    }
+                }
+                finish = true;
+                for (int i = 0;i < 10 ;i++) {
+                    finish = finish && (threads[i].getState() == Thread.State.TERMINATED);//中断
+                }
+            }
+        } catch (IOException e) {
+            e.printStackTrace();
+        }
+    }
+
+    private static void writeThreadInfo(PrintWriter pw, Thread thread, Thread.State status) {
+        pw.printf("Main: Id %d - $s\n",thread.getId(),thread.getName());
+        pw.printf("Main: Priority: %d\n",thread.getPriority());
+        pw.printf("Main: OldState: %s\n",status);
+        pw.printf("Main: New State: %s\n",thread.getState());
+        pw.printf("*****************************************\n");
+    }
+}
+class Calculator implements Runnable {
+
+    private int number;
+
+    public Calculator(int number) {
+        this.number = number;
+    }
+
+    @Override
+    public void run() {
+        for (int i = 0;i <=10; i++) {
+            System.out.printf("%s: %d * %d = %d\n",
+                    Thread.currentThread().getName(),
+                    number, i, i * number);
+        }
+    }
+}

src/org/javacore/thread/ThreadInterrupt.java

@@ -0,0 +1,22 @@
+package org.javacore.thread;
+
+/**
+ * Created by bysocket on 16/2/24.
+ */
+public class ThreadInterrupt {
+    public static void main(String[] args) throws InterruptedException {
+        Thread inThread = new Thread(new InterrupThread());
+        inThread.start();
+        Thread.sleep(1000);
+        inThread.interrupt();
+    }
+}
+class InterrupThread implements Runnable {
+
+    private int num = 1;
+    @Override
+    public void run() {
+        while (true)
+            System.out.println("true ----> " + num++);
+    }
+}