線程池存在的意義

語言: CN / TW / HK

持續創作,加速成長!這是我參與「掘金日新計劃 · 6 月更文挑戰」的第4天,點擊查看活動詳情

前言

  • 再次之前我已經花費大量篇幅介紹了Java原聲鎖和Lock鎖。在文章中提到偏向送、輕量級鎖、重量級鎖、公平鎖、非公平鎖、自旋鎖、自適應自旋鎖、分佈式鎖、分段鎖等等鎖。所有的鎖都是為了解決一個問題應運而生的那就是併發。而產生併發的原因是CPU的發展導致我們程序多線程運行。在代碼中我們也經常通過多線程來提高產品的吞吐量。
  • 在鎖章節中我們也是通過多線程案例模擬鎖的產生的。那麼Java領域中有哪幾種方式生成線程呢?容我慢慢道來

創建線程

繼承Thread

  • 創建線程的方式Java為我們提供了四種方式,首先是繼承Thread 。複寫run方法就可以了。

public class ExtendThread extends Thread{      private Integer index;  ​      public ExtendThread(Integer index) {          this.index = index;     }      @Override      public void run() {          System.out.println("當前索引值:"+index);     }  ​      public static void main(String[] args) {          for (int i = 0; i < 100; i++) {              new ExtendThread(i).start();         }     }  }

實現Runnable接口

  • 第二種方式就是實現Runnable接口。我們點進Thread源碼也能看到,thread的構造需要一個Runnable接口。

public class TestRunnable implements Runnable{      private String userName;  ​      public TestRunnable(String userName) {          this.userName = userName;     }      @SneakyThrows      @Override      public void run() {          TimeUnit.SECONDS.sleep(1);          System.out.println("當前名稱:"+userName);     }  ​      public static void main(String[] args) {          for (int i = 0; i < 100; i++) {              new Thread(new TestRunnable(String.format("我是%s", i))).start();         }     }  }

實現Callable接口

  • 除了上面兩種還有一個接口實現。還有一個Callable他和Runnable的區別在於有返回值

public class TestCallable implements Callable {      private int i;  ​      public TestCallable(int i) {          this.i = i;     }      @Override      public Object call() throws Exception {          System.out.println(Thread.currentThread()+"我是"+i);          return i;     }  ​      public static void main(String[] args) throws ExecutionException, InterruptedException {          final FutureTask futureTask = new FutureTask(new TestCallable(1));          for (int i = 0; i < 100; i++) {              new Thread(new FutureTask(new TestCallable(i))).start();         }          System.out.println(futureTask.get());     }  }

線程池

  • 上面三種應該算是線程創建的基本方式。為了提高性能減少線程的開闢與銷燬,JDK提出了線程池的概念。線程池主要是在線程閒置後進行回收防止被JVM銷燬。這樣下次在來任務的時候就可以直接將閒置的線程提供給任務使用就可以了。線程池的創建默認有三種方式。這裏我們使用其中一種,至於線程池我們後面會着重介紹。

public class TPools {      public static void main(String[] args) {          final ExecutorService executorService = Executors.newCachedThreadPool();          for (int i = 0; i < 100; i++) {  ​              int finalI = i;              executorService.execute(new Runnable() {                  @Override                  public void run() {                      System.out.println("@@@@@"+ finalI);                 }             });         }     }  }

小結

  • 本章節我們簡單介紹了四種方式創建線程。使用上沒有區別。需要注意Callable接口是具有返回值的。這種方式其實我們可以用來確認線程是否執行了。然後就是線程池方式創建。從線程的角度四種方式創建出來的線程具有同等性質。不同的是線程池會對線程進行回收管理。關於他的回收策略JDK給我們提供了不同的默認策略。也支持我們自定義線程結構。

\