public class MyThread extends Thread{//繼承Thread類
　　public void run(){
　　//重寫run方法
　　}
}
public class Main {
public static void main(String[] args){
　　　　new MyThread().start();//創(chuàng)建并啟動(dòng)線程
　　}
}

public class MyThread2 implements Runnable {//實(shí)現(xiàn)Runnable接口
　　public void run(){
　　//重寫run方法
　　}
}
public class Main {
　　public static void main(String[] args){
　　　　//創(chuàng)建并啟動(dòng)線程
　　　　MyThread2 myThread=new MyThread2();
　　　　Thread thread=new Thread(myThread);
　　　　thread().start();
　　　　//或者  new Thread(new MyThread2()).start();
　　}
}

public class Main {
　　public static void main(String[] args){
　　　MyThread3 th=new MyThread3();
　　　//使用Lambda表達(dá)式創(chuàng)建Callable對(duì)象
　　 //使用FutureTask類來包裝Callable對(duì)象
　　　FutureTask<Integer> future=new FutureTask<Integer>(
　　　　(Callable<Integer>)()->{
　　　　　　return 5;
　　　　}
　　 );
　　　new Thread(task,"有返回值的線程").start();//實(shí)質(zhì)上還是以Callable對(duì)象來創(chuàng)建并啟動(dòng)線程
　　 try{
　　　　System.out.println("子線程的返回值："+future.get());//get()方法會(huì)阻塞，直到子線程執(zhí)行結(jié)束才返回
　　 }catch(Exception e){
　　　　ex.printStackTrace();
　　　}
　　}
}

/**
   * synchronized添加到方法上面，使方法變成同步方法
   * 如果是靜態(tài)方法，鎖住的是class
   * 如果是普通方法，鎖住的this,當(dāng)前對(duì)象 synchronized(this)
   * 多個(gè)線程鎖住的對(duì)象是同一個(gè)對(duì)象才能夠同步，每個(gè)類都有當(dāng)前對(duì)象
   */

  public static synchronized void salTicket(){
    if (ticketNum > 0) {
      try {
        Thread.sleep(100);
      } catch (InterruptedException e) {
        e.printStackTrace();
      }
      System.out.println(Thread.currentThread().getName() + "買到第" + ticketNum-- + "張票");
      System.out.println(Thread.currentThread().getName() + "買票完成");
    }else {
      System.out.println("票已經(jīng)售完，"+Thread.currentThread().getName() + "未買到票");
    }
  }

/**
   * 同步代碼塊
   */
  public void salTicket2() {
    synchronized (this) {
      //()中指定鎖對(duì)象，this表示當(dāng)前對(duì)象，多個(gè)線程使用同一個(gè)對(duì)象調(diào)用該方法時(shí)，是同步的
      //如果指定為 class，則該類的任意對(duì)象調(diào)用該方法都是同步的
      if (ticketNum > 0) {
        try {
          Thread.sleep(100);
        } catch (InterruptedException e) {
          e.printStackTrace();
        }
        System.out.println(Thread.currentThread().getName() + "買到第" + ticketNum-- + "張票");
        System.out.println(Thread.currentThread().getName() + "買票完成");
      } else {
        System.out.println("票已經(jīng)售完，" + Thread.currentThread().getName() + "未買到票");
      }
    }
  }

//鎖對(duì)象 private static ReentrantLock lock=new ReentrantLock();
 /**
   * 使用lock對(duì)象進(jìn)行同步,多個(gè)線程使用的是同一個(gè)lock對(duì)象，才會(huì)是同步的
   */
  public void salTicket3() {
    lock.lock();//加鎖
      if (ticketNum > 0) {
        try {
          Thread.sleep(100);
        } catch (InterruptedException e) {
          e.printStackTrace();
        }finally {
          lock.unlock();//釋放鎖，必須放在finally代碼塊中，以確保能夠釋放鎖
        }
        System.out.println(Thread.currentThread().getName() + "買到第" + ticketNum-- + "張票");
        System.out.println(Thread.currentThread().getName() + "買票完成");
      } else {
        System.out.println("票已經(jīng)售完，" + Thread.currentThread().getName() + "未買到票");
      }
  }

//jdk中提供的四種快速創(chuàng)建線程池的方式
    //1.定長線程池
    ExecutorService fixedThreadPool = Executors.newFixedThreadPool(10);
    //2.緩存線程池
    ExecutorService cachedThreadPool = Executors.newCachedThreadPool();
    //3.周期線程池,可用來實(shí)現(xiàn)定時(shí)任務(wù)
    ScheduledExecutorService scheduledExecutorService = Executors.newScheduledThreadPool(10);
    //4.單線程線程池
    ExecutorService executorService = Executors.newSingleThreadExecutor();