JAVA多線程的用法

//方法一：
//定義Thread類的子類，并重寫該類的run()方法
public class MyThreadDemo01 extends Thread {
  @Override
  public void run() {
    for (int i = 0; i < 20 ; i++) {
      System.out.println(getName()+"-->"+i);
    }
  }
}

//主線程
public class MainThread01 {
  public static void main(String[] args) {
    //創(chuàng)建Thread子類的實(shí)例，即創(chuàng)建了線程對(duì)象
    MyThreadDemo01 thread01 = new MyThreadDemo01();

    //調(diào)用線程對(duì)象的start()方法來啟動(dòng)該線程
    thread01.start();

    for (int i = 0; i < 10 ; i++) {
      System.out.println(Thread.currentThread().getName()+"-->"+i);
    }
  }
}

//方法二：
//定義Runnable接口的實(shí)現(xiàn)類，并重寫該接口的run()方法，設(shè)置線程任務(wù)
public class MyThreadDemo02 implements Runnable{
  @Override
  public void run() {
    for (int i = 0; i < 10 ; i++) {
      System.out.println(Thread.currentThread().getName()+"-->"+i);
    }
  }
}

 //主線程
public class MainThread {
  public static void main(String[] args) {  
    //創(chuàng)建Runnable實(shí)現(xiàn)類對(duì)象
    MyThreadDemo02 runnable = new MyThreadDemo02();

    //創(chuàng)建Thread類的對(duì)象，并且該對(duì)象構(gòu)造方法中傳遞Runnable實(shí)現(xiàn)類對(duì)象
    Thread thread02 = new Thread(runnable);

    //調(diào)用Thread對(duì)象的start()方法來啟動(dòng)線程
    thread02.start();

    for (int i = 0; i < 20 ; i++) {
      System.out.println(Thread.currentThread().getName()+"-->"+i);
    }
  }
}

//方法三：匿名內(nèi)部類
public class MainThread {
  public static void main(String[] args) {
    //Thread方式
    new Thread(){
      @Override
      public void run() {
        for (int i = 0; i < 10 ; i++) {
          System.out.println(Thread.currentThread().getName()+"-->"+i);
        }
      }
    }.start();
    //Runnable接口方式
	 new Thread(new Runnable() {
      @Override
      public void run() {
        for (int i = 0; i < 10 ; i++) {
          System.out.println(Thread.currentThread().getName()+"-->"+i);
        }
      }
    }).start();
    ////////////////////////////////////////////////

    for (int i = 0; i < 20 ; i++) {
      System.out.println(Thread.currentThread().getName()+"-->"+i);
    }
  }
}

public class SafeRunnableDemo implements Runnable {
  private int ticket = 100;

  //同步代碼塊
  //創(chuàng)建鎖對(duì)象
  Object lock = new Object();

  @Override
  public void run() {
    while (true){
      //鎖住同步代碼塊
      synchronized (lock){
        if (ticket > 0) {
          System.out.println(Thread.currentThread().getName() + "正在賣第" + ticket + "張");
          ticket--;
        }
      }
    }
  }
}

public class SafeRunnableDemo implements Runnable {
  private int ticket = 100;

  //同步方法
  //定義一個(gè)同步方法
  public synchronized void lock(){
    //同步方法鎖住代碼塊
    if (ticket > 0) {
      System.out.println(Thread.currentThread().getName() + "正在賣第" + ticket + "張");
      ticket--;
    }
  }

  //重寫run并使用同步方法
  @Override
  public void run() {
    while (true){
      lock();
    }
  }
}

import java.util.concurrent.locks.Lock;
import java.util.concurrent.locks.ReentrantLock;

public class SafeRunnableDemo implements Runnable {
  private int ticket = 100;

  //Lock鎖方法
  //創(chuàng)建ReentrantLock對(duì)象
  Lock lock = new ReentrantLock();
  @Override
  public void run() {
    while (true){
      //在可能出現(xiàn)問題的代碼塊之前用lock()方法
      lock.lock();
      if (ticket > 0) {
        System.out.println(Thread.currentThread().getName() + "正在賣第" + ticket + "張");
        ticket--;
      }
      //在可能出現(xiàn)問題的代碼塊之后用unlock()方法
      lock.unlock();
    }
  }
}

public class WaitAndSleep {
  public static void main(String[] args) {
    //創(chuàng)建鎖對(duì)象
    Object lock = new Object();

    //匿名內(nèi)部類創(chuàng)建線程1
    new Thread(){
      @Override
      public void run() {
        System.out.println(Thread.currentThread().getName()+"需要買票");
        //用同步代碼塊包裹
        synchronized (lock){
          try {
            //lock.wait(5000);//到5秒自動(dòng)醒來
            lock.wait();//進(jìn)入無(wú)限等待，需要喚醒
          } catch (InterruptedException e) {
            e.printStackTrace();
          }
        }
        System.out.println(Thread.currentThread().getName()+"買到了票");
      }
    }.start();

    //匿名內(nèi)部類創(chuàng)建線程2
    new Thread(){
      @Override
      public void run() {
        try {
          Thread.sleep(5000);//等待5秒
          System.out.println(Thread.currentThread().getName()+"出票了");
        } catch (InterruptedException e) {
          e.printStackTrace();
        }
        //用同步代碼塊包裹
        synchronized (lock){
          lock.notify();//如果有多個(gè)線程等待，隨機(jī)喚醒一個(gè)
          //lock.notifyAll();//喚醒所有等待的線程
        }
      }
    }.start();
  }
}

import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;

//線程池
public class ThreadPoolMain {
  public static void main(String[] args) {
    //使用線程池的工廠類 Executors里的靜態(tài)方法 newFixedThreadPool
    // 生產(chǎn)指定線程數(shù)量的線程池，返回為ExecutorService接口
    ExecutorService es = Executors.newFixedThreadPool(2);

    //調(diào)用ExecutorService中的submit方法，傳遞線程任務(wù)，開啟線程
    es.submit(new ThreadPoolDemo01());
  }
}

//////////////////////////////////////////////////////

//創(chuàng)建一個(gè)類實(shí)現(xiàn)Runnable接口，重寫run方法，設(shè)置線程任務(wù)
public class ThreadPoolDemo01 implements Runnable{
  @Override
  public void run() {
    ...
  }
}