Java Thread 部分方法及概念

这里并不打算说明什么叫线程，但是可以简单举一线程的应用场景：

 

现有一拷贝程序，当我在拷贝一个非常大的文件时，突然想终止其拷贝，一个办法就是直接把该拷贝程序的进程kill，还有一办法就是多线程机制，一个线程专用于拷贝程序，另一线程监听中途终止的指令，一旦接受到其指令，马上要求另一线程停止操作。

 

优先级：线程的初始化优先级与创建此线程的线程的优先级一样。

 

守护进程(daemon)：如果创建线程是守护线程那么创建出来的线程也是守护线程。如果所有非守护线程都已经停止运行，那些守护线程将被程序杀死，程序结束运行，main线程就是典型的非守护线程。ps:只有在线程启动之前setDaemon()才能将其设置为守护线程。

 

任务：通常一个实现了Runnble接口的类就是一个任务，任务就是我们在run方法中要做的事情。任务由线程来驱动，也就是说任务最终是要靠线程去帮其完成的。

 

异常捕获：run方法中产生的异常没法直接通过try catch捕获。比如：

package com.lzjun.remotecopy;

public class ExceptionCapture {
      
       public static void main(String[] args) {
            
             try {
                  ExceptionThread thread = new ExceptionThread();
                  thread.start();
            } catch (Exception e){
                  System. out .println("catch thread exception" );
            }
      }
}

class ExceptionThread extends Thread{
      
       @Override
       public void run() {
             throw new RuntimeException( "exception...");
      }
}

 

输出结果只有：

Exception in thread "Thread-0" java.lang.RuntimeException : exception...

      at com.lzjun.remotecopy.ExceptionThread.run( RemoteCopy.java:25 )

 

要想捕获该异常只需在线程上注册一个UncaughtExceptionHandler

 

try {
			ExceptionThread thread = new ExceptionThread();
			thread.setUncaughtExceptionHandler(new Thread.UncaughtExceptionHandler() {

				@Override
				public void uncaughtException(Thread t, Throwable e) {
					// 异常处理
				}
			});
			thread.start();
		} catch (Exception e) {
			System.out.println("catch thread exception");
		}

 

Thread.yield()：静态方法，Causes the currently executing thread object to temporarily pause and allow other threads to execute.(致使当前的执行线程对象临时暂停运行，允许其他线程执行）此说明来自于jdk中的文档 ，其实并不能做到真正的暂停，这只是虚拟机对线程调度器的一种建议：“我休息会儿，其他线程赶紧做你们重要的事去吧“

 

join()：实例方法，等待该线程终止。如果在当前线程中调用t.join()方法，那么当前线程就会挂起，直到t线程执行完才恢复。 

来看一个join（)的代码片段：

执行cmd命令的任务

public class ExecutorTask implements Runnable{

    @Override
    public void run() {

        Process process = null;
        try {
            process = Runtime.getRuntime().exec("cmd /c dir");
             BufferedReader reader = new BufferedReader(new InputStreamReader(process.getInputStream()));
             String line="";
             while ((line = reader.readLine()) != null) {
                 System.out.println(line);
             }
            process.waitFor();
        } catch (IOException e) {
            e.printStackTrace();
        } catch (InterruptedException e) {
            return;
        }
    }
}

 

执行cmd任务的执行器

public final class ShellCommandExecutor{

    public void execute(String command){

        ExecutorTask task = new ExecutorTask();
        Thread executorThread = new Thread(task);
        executorThread.start();
        
        //如果此段代码注释掉，你将看不到命令执行后返回的结果
                 try {
			executorThread.join();
		} catch (InterruptedException e) {
			e.printStackTrace();
		}
      
    }

}

 

interrupt()：实例方法，调用一个线程对象的interrupt方法时，如果该线程在执行一个阻塞方法如Thread.sleep()、Object.wait()、join()方法时，那么首先就会设置线程的中断状态，接着线程将取消阻塞，与此同时抛出InterrputException异常，线程终止执行任务。另一种情况就是该线程没有执行阻塞方法时，调用interrupt()只设定线程的中断状态，程序会一致运行直至自身执行完毕，也就是说当一个线程中断另外一个线程时，被中断的线程不一定立即停止执行当前在做的事情。

 

public class TestThread {

       public static void main(String[] args) {

            Thread thread = new Thread( new TestTask());
            thread.start();
            thread.interrupt();
      }
}

class TestTask implements Runnable {

       @Override
       public void run() {

                   while (true ) {
                         //Thread.sleep(100);
                        System. out .println("h" );
                  }

      }
}

 

如上代码段：线程并不会应为线程中断而停止任务的执行，只有在线程遇到阻塞方法时才会停止任务的执行。

 

            try {
                   while (true ) {
                        Thread. sleep(100);
                        System. out .println("h" );
                  }
            } catch (InterruptedException e) {
                  e. printStackTrace();
            }

 
isInterrupted()：实例方法，测试线程是否中断。

interrputed()：类方法，测试当前线程是否已经中断，之后清除中断状态。

 

            Thread.currentThread ().interrupt();
            System. out .println(Thread.interrupted());
            System. out .println(Thread.interrupted());

 

打印结果就是：true /  false

 

参考：

 

http://www.ibm.com/developerworks/cn/java/j-jtp05236.html

http://stackoverflow.com/questions/12121416/use-java-execute-command-with-thread-sleep

http://hapinwater.iteye.com/blog/310558