java多线程入门（一）

public class HelloThread extends Thread{
  @Override
  public void run() {
    System.out.println("thread");
  }
  public static void main(String[] args) {
    Thread th=new HelloThread();
    th.start();
  }
}
复制代码

public class HelloThreadImp implements Runnable{
  @Override
  public void run() {
    System.out.println("rannable");
  }
  public static void main(String[] args) {
    Runnable hti=new HelloThreadImp();
    Thread t=new Thread(hti);
    t.start();
  }
}
复制代码

public class HellloThreadCallable implements Callable<String>  {
  @Override
  public String call() throws Exception {
    return "threadCallable";
  }
  public static void main(String[] args) throws InterruptedException, ExecutionException {
    HellloThreadCallable htc=new HellloThreadCallable();
    FutureTask<String> ft=new FutureTask<String>(htc);
    new Thread(ft).start();
    String result=ft.get();
    System.out.println(result);
  }
}
复制代码

Thread.isInterrupted() //判断是否被中断 
Thread.interrupted()   //判断是否被中断，并清除当前中断状态 注意第二次调用返回false
                       //遇到Thread.sleep会报异常
复制代码

public class ThreadInterrupt implements Runnable {
  @Override
  public void run() {
    int i = 0;
    while (true) {
      if (Thread.currentThread().isInterrupted()) {
        System.out.println("线程终止");
        return;
      } else {
        System.out.println(++i);
        if (i % 10000 == 0) {
          try {
            Thread.sleep(1000);
          } catch (InterruptedException e) {
            e.printStackTrace();
            return;
          }
        }
      }
    }
  }
  public static void main(String[] args) throws InterruptedException {
    ThreadInterrupt ti = new ThreadInterrupt();
    Thread t = new Thread(ti);
    t.start();
    Thread.sleep(200);
    t.interrupt();
  }
}
复制代码