快捷導(dǎo)航

java 創(chuàng)建線(xiàn)程的四種方式

更新時(shí)間：2020年11月13日 08:28:17 作者：(•̀ω•́)y

這篇文章主要介紹了java 創(chuàng)建線(xiàn)程的四種方式，幫助大家更好的理解和使用Java，感興趣的朋友可以了解下

1、繼承Thread類(lèi)方式

這種方式適用于執(zhí)行特定任務(wù)，并且需要獲取處理后的數(shù)據(jù)的場(chǎng)景。

舉例：一個(gè)用于累加數(shù)組內(nèi)數(shù)據(jù)的和的線(xiàn)程。

public class AdditionThread extends Thread {
 private int sum = 0;
 private int[] nums;

 public AdditionThread(int[] nums, String threadName) {
  super(threadName);
  this.nums = nums;
 }

 @Override
 public void run() {
  for (int num : nums) {
   sum += num;
  }
 }

 public int getSum() {
  return sum;
 }
}

調(diào)用方式：

public class Main {
 public static void main(String[] args) throws InterruptedException {
  int[] nums = {10, 12, 15, 200, 100};
  AdditionThread thread = new AdditionThread(nums, "AdditionThread");
  thread.start();
  thread.join();

  System.out.println("sum=" + thread.getSum());
 }
}

2、Runnable 接口方式

定義一個(gè)實(shí)現(xiàn)Runnable接口的類(lèi)，或者直接創(chuàng)建一個(gè)匿名內(nèi)部類(lèi)，并覆蓋 run() 方法。最后作為參數(shù)傳給Thread的構(gòu)造函數(shù)。

public class Main {
 public static void main(String[] args) {
  // 自定義的 Runnable
  Runnable runnable = new MyRunnable();
  Thread thread = new Thread(runnable, "Runnable-Thread");
  thread.start();

  // 自定義匿名內(nèi)部類(lèi)
  new Thread(() -> {
   System.out.println("Inner class");
  }).start();
 }

 static class MyRunnable implements Runnable {
  @Override
  public void run() {
   System.out.println("MyRunnable");
  }
 }
}

3、 Callable 接口方式

Callable 接口與 Runnable 接口的區(qū)別：

（1）Callable 的方法為call()，Runnable的方法為run()。

（2）Callable 的方法由返回值，Runnable 沒(méi)有。

（3）Callable 的方法聲明的Exception，Runnable的沒(méi)有。

public class Main {
 public static void main(String[] args) {
  MyCallable myCallable = new MyCallable();
  FutureTask<String> task = new FutureTask<>(myCallable);
  Thread thread = new Thread(task, "FutureTask");
  thread.start();
  try {
   // 通過(guò)get方法獲取返回值
   String result = task.get();
   System.out.println(result);
  } catch (InterruptedException | ExecutionException e) {
   e.printStackTrace();
  }
 }

 static class MyCallable implements Callable<String> {
  @Override
  public String call() throws Exception {
   // 模擬超時(shí)操作
   Thread.sleep(1000);
   return "OK";
  }
 }
}

4、線(xiàn)程池方式

我們可以通過(guò) ThreadPoolExecutor 類(lèi)的構(gòu)造函數(shù)來(lái)創(chuàng)建線(xiàn)程池，也可以通過(guò)Executors工廠(chǎng)方法來(lái)創(chuàng)建，如

// 創(chuàng)建固定線(xiàn)程數(shù)的線(xiàn)程池
Executors.newFixedThreadPool(); 
// 創(chuàng)建只有一個(gè)核心線(xiàn)程的線(xiàn)程池
Executors.newSingleThreadExecutor();
// 創(chuàng)建一個(gè)沒(méi)有核心線(xiàn)程，但可以緩存線(xiàn)程的線(xiàn)程池
Executors.newCachedThreadPool();
// 創(chuàng)建一個(gè)適用于執(zhí)行定時(shí)任務(wù)的線(xiàn)程池
Executors.newScheduledThreadPool();

在創(chuàng)建線(xiàn)程池時(shí)，最好傳入 ThreadFactory 參數(shù)，指定線(xiàn)程池所創(chuàng)建線(xiàn)程的名稱(chēng)。這樣有利于分析定位可能存在的問(wèn)題。

public class Main {
 private static final ExecutorService SERVICE =
  Executors.newFixedThreadPool(5, new BasicThreadFactory("My-Thread"));

 public static void main(String[] args) {
  // 打印線(xiàn)程的名字
  System.out.println("main thread name:" + Thread.currentThread().getName());
  SERVICE.execute(() -> {
   System.out.println("Hello thread pool.");
   // 打印線(xiàn)程池里的線(xiàn)程的名字
   System.out.println("thread name:" + Thread.currentThread().getName());
  });
 }

 static class BasicThreadFactory implements ThreadFactory {
  private final AtomicInteger threadNumber = new AtomicInteger(0);
  private final String basicName;

  public BasicThreadFactory(String basicName) {
   this.basicName = basicName;
  }

  @Override
  public Thread newThread(Runnable runnable) {
   Thread thread = new Thread(runnable);
   String name = this.basicName + "-" + threadNumber.incrementAndGet();
   thread.setName(name);
   return thread;
  }
 }
}

以上就是java 創(chuàng)建線(xiàn)程的四種方式的詳細(xì)內(nèi)容，更多關(guān)于java 創(chuàng)建線(xiàn)程的資料請(qǐng)關(guān)注腳本之家其它相關(guān)文章！

您可能感興趣的文章: