java 创建线程的四种方式

时间：2021-05-23 08:04:38|栏目：JAVA代码|点击：次

1、继承Thread类方式

这种方式适用于执行特定任务，并且需要获取处理后的数据的场景。

举例：一个用于累加数组内数据的和的线程。

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;
 }
}

调用方式：

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 接口方式

定义一个实现Runnable接口的类，或者直接创建一个匿名内部类，并覆盖 run() 方法。最后作为参数传给Thread的构造函数。

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

  // 自定义匿名内部类
  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 接口的区别：

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

（2）Callable 的方法由返回值，Runnable 没有。

（3）Callable 的方法声明的Exception，Runnable的没有。

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 {
   // 通过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 {
   // 模拟超时操作
   Thread.sleep(1000);
   return "OK";
  }
 }
}

4、线程池方式

我们可以通过 ThreadPoolExecutor 类的构造函数来创建线程池，也可以通过Executors工厂方法来创建，如

// 创建固定线程数的线程池
Executors.newFixedThreadPool(); 
// 创建只有一个核心线程的线程池
Executors.newSingleThreadExecutor();
// 创建一个没有核心线程，但可以缓存线程的线程池
Executors.newCachedThreadPool();
// 创建一个适用于执行定时任务的线程池
Executors.newScheduledThreadPool();

在创建线程池时，最好传入 ThreadFactory 参数，指定线程池所创建线程的名称。这样有利于分析定位可能存在的问题。

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

 public static void main(String[] args) {
  // 打印线程的名字
  System.out.println("main thread name:" + Thread.currentThread().getName());
  SERVICE.execute(() -> {
   System.out.println("Hello thread pool.");
   // 打印线程池里的线程的名字
   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中ListIterator和Iterator详解与辨析(推荐)

栏目：JAVA代码

下一篇：spring boot 集成shiro的配置方法

本文标题：java 创建线程的四种方式

本文地址：http://www.codeinn.net/misctech/126901.html

更多JAVA代码

JAVA代码

java 创建线程的四种方式

阅读排行

推荐教程