devbox
不正经
这个屌丝很懒，什么也没留下！
关注作者
热门标签
热门文章
当前位置:   article > 正文

Java中创建线程的多种方式实例

作者：不正经 | 2024-03-27 10:25:08

赞

踩

Java中创建线程的多种方式实例

目录

1、普通Thread创建

2、实现Runnable接口创建线程

3、匿名方式创建

4、使用Lambda表达式创建线程

5、实现Callable接口创建线程

6、线程池方式

7、线程工具类

在Java中创建线程的方式有多种，以下是几种常见的创建线程的方式，选择哪种方式取决于具体的需求和设计。需要注意的是，在使用多线程时，要确保线程安全，避免出现并发问题。

1、普通Thread创建

  1. //继承创建线程
  2.     static class NewThread extends Thread {
  3.         @Override
  4.         public void run() {
  5.             System.out.println("继承Thread创建线程-1 = " + DateUtils.getNowTime());
  6.             try {
  7.                 sleep(1000);
  8.             } catch (InterruptedException e) {
  9.                 throw new RuntimeException(e);
  10.             }
  11.             System.out.println("继承Thread创建线程-2 = " + DateUtils.getNowTime());
  12.  
  13.         }
  14.     }

启动线程

  1.         //普通Thread创建
  2.         NewThread nt = new NewThread();
  3.         nt.start();

2、实现Runnable接口创建线程

  1. // 实现Runnable接口创建线程
  2.     static class NewRunnable implements Runnable {
  3.         @Override
  4.         public void run() {
  5.  
  6.             System.out.println("实现Runnable接口-3 = " + DateUtils.getNowTime());
  7.  
  8.             //等待
  9.             try {
  10.                 Thread.sleep(2000);
  11.             } catch (InterruptedException e) {
  12.                 throw new RuntimeException(e);
  13.             }
  14.             System.out.println("实现Runnable接口-4 = " + DateUtils.getNowTime());
  15.         }
  16.     }

启动线程

  1.         //普通Runnable创建
  2.         NewRunnable nr = new NewRunnable();
  3.         Thread t = new Thread(nr);
  4.         t.start();

3、匿名方式创建

  1.         //匿名Thread创建
  2.         Thread t1 = new Thread(new Thread() {
  3.             @Override
  4.             public void run() {
  5.                 System.out.println("匿名Thread" + DateUtils.getNowTime());
  6.             }
  7.         });
  8.         t1.start();
  9.  
  10.  
  11.         //匿名Runnable创建
  12.         Thread t2 = new Thread(new Runnable() {
  13.             @Override
  14.             public void run() {
  15.                 System.out.println("匿名Runnable创建 = " + DateUtils.getNowTime());
  16.             }
  17.         });
  18.         t2.start();

4、使用Lambda表达式创建线程

  1.  
  2.         //使用Lambda表达式创建线程
  3.         Thread t3 = new Thread(() -> System.out.println("Lambda表达式创建1 = " + DateUtils.getNowTime()));
  4.         t3.start();
  5.  
  6.         Runnable r = () -> {
  7.             System.out.println("Lambda表达式创建2 = " + DateUtils.getNowTime());
  8.         };
  9.         Thread t4 = new Thread(r);
  10.         t4.start();
  11.

5、实现Callable接口创建线程

在使用这个 Callable创建线程的时候，是有返回值的线程调用

  1.     /**
  2.      * 实现Callable接口创建线程
  3.      * 是有返回值的线程调用
  4.      */
  5.     static class NewCallable implements Callable<String> {
  6.         @Override
  7.         public String call() throws Exception {
  8.             System.out.println("实现Callable接口创建线程-5 = " + DateUtils.getNowTime());
  9.             Thread.sleep(3000);
  10.             System.out.println("实现Callable接口创建线程-6 = " + DateUtils.getNowTime());
  11.             return "Callable接口创建线程";
  12.         }
  13.     }

启动线程

  1.         //调用callable创建线程
  2.         Callable<String> callable = new Callable<String>() {
  3.             @Override
  4.             public String call() throws Exception {
  5.                 return "callable创建线程";
  6.             }
  7.         };
  8.         //FutureTask<String> futureTask = new FutureTask<>(callable);
  9.  
  10.         // 调用NewCallable()
  11.         FutureTask<String> futureTask = new FutureTask<>(new NewCallable());
  12.         Thread t5 = new Thread(futureTask);
  13.         t5.start();

6、线程池方式

创建线程池的时候，可以定义线程池的大小，线程池中可以执行多个任务。若需要获取异步执行任务的返回值的话，使用submit方法；若是让一个任务在线程池中异步执行，使用execute方法即可。
  1. //         相同点：
  2. //         submit和execute方法均可以像线程池中提交一个任务，让线程池来异步执行这个任务
  3. //         不同点：
  4. //         submit可以接受Runnable和Callable任务，但execute只能接受Runnable任务；
  5. //         submit方法的返回值是一个Future，而execute方法的返回值是void；
  6. //         对于异常的处理，使用submit方式提交的任务若在执行的过程中抛出了异常的话，异常信息在控制台中看不到，需要通过Future.get方法来获取这个异常；
  7. //         使用execute方式提交的任务若在执行的过程中出现异常的话，异常信息会被打印到控制台;
  8.  
  9.         // 创建一个10个大小的线程池
  10.         ExecutorService executorService = Executors.newFixedThreadPool(10);
  11.         // 提交任务到线程池、创建一个线程
  12.         executorService.submit(new NewRunnable());
  13.         // 执行一个任务
  14.         executorService.execute(new Runnable() {
  15.             @Override
  16.             public void run() {
  17.                 System.out.println("线程池创建线程 = " + DateUtils.getNowTime());
  18.             }
  19.         });
  20.         // 关闭线程池
  21.         executorService.shutdown();

7、线程工具类

  1.  
  2. import com.terra.utils.DateUtils;
  3.  
  4. import java.util.concurrent.Callable;
  5. import java.util.concurrent.ExecutorService;
  6. import java.util.concurrent.Executors;
  7. import java.util.concurrent.FutureTask;
  8.  
  9. public class T1 {
  10.  
  11.     public static void main(String[] args) {
  12.  
  13.         //普通Thread创建
  14.         NewThread nt = new NewThread();
  15.         nt.start();
  16.  
  17.         //匿名Thread创建
  18.         Thread t1 = new Thread(new Thread() {
  19.             @Override
  20.             public void run() {
  21.                 System.out.println("匿名Thread" + DateUtils.getNowTime());
  22.             }
  23.         });
  24.         t1.start();
  25.  
  26.         //普通Runnable创建
  27.         NewRunnable nr = new NewRunnable();
  28.         Thread t = new Thread(nr);
  29.         t.start();
  30.  
  31.         //匿名Runnable创建
  32.         Thread t2 = new Thread(new Runnable() {
  33.             @Override
  34.             public void run() {
  35.                 System.out.println("匿名Runnable创建 = " + DateUtils.getNowTime());
  36.             }
  37.         });
  38.         t2.start();
  39.  
  40.         //使用Lambda表达式创建线程
  41.         Thread t3 = new Thread(() -> System.out.println("Lambda表达式创建1 = " + DateUtils.getNowTime()));
  42.         t3.start();
  43.  
  44.         Runnable r = () -> {
  45.             System.out.println("Lambda表达式创建2 = " + DateUtils.getNowTime());
  46.         };
  47.         Thread t4 = new Thread(r);
  48.         t4.start();
  49.  
  50.  
  51.         //调用callable创建线程
  52.         Callable<String> callable = new Callable<String>() {
  53.             @Override
  54.             public String call() throws Exception {
  55.                 return "callable创建线程";
  56.             }
  57.         };
  58.         //FutureTask<String> futureTask = new FutureTask<>(callable);
  59.  
  60.         // 调用NewCallable()
  61.         FutureTask<String> futureTask = new FutureTask<>(new NewCallable());
  62.         Thread t5 = new Thread(futureTask);
  63.         t5.start();
  64.  
  65.  
  66. //         相同点：
  67. //         submit和execute方法均可以像线程池中提交一个任务，让线程池来异步执行这个任务
  68. //         不同点：
  69. //         submit可以接受Runnable和Callable任务，但execute只能接受Runnable任务；
  70. //         submit方法的返回值是一个Future，而execute方法的返回值是void；
  71. //         对于异常的处理，使用submit方式提交的任务若在执行的过程中抛出了异常的话，异常信息在控制台中看不到，需要通过Future.get方法来获取这个异常；
  72. //         使用execute方式提交的任务若在执行的过程中出现异常的话，异常信息会被打印到控制台;
  73.  
  74.         // 创建一个10个大小的线程池
  75.         ExecutorService executorService = Executors.newFixedThreadPool(10);
  76.         // 提交任务到线程池、创建一个线程
  77.         executorService.submit(new NewRunnable());
  78.         // 执行一个任务
  79.         executorService.execute(new Runnable() {
  80.             @Override
  81.             public void run() {
  82.                 System.out.println("线程池创建线程 = " + DateUtils.getNowTime());
  83.             }
  84.         });
  85.         // 关闭线程池
  86.         executorService.shutdown();
  87.  
  88.  
  89.     }
  90.  
  91.     //继承创建线程
  92.     static class NewThread extends Thread {
  93.         @Override
  94.         public void run() {
  95.             System.out.println("继承Thread创建线程-1 = " + DateUtils.getNowTime());
  96.             try {
  97.                 sleep(1000);
  98.             } catch (InterruptedException e) {
  99.                 throw new RuntimeException(e);
  100.             }
  101.             System.out.println("继承Thread创建线程-2 = " + DateUtils.getNowTime());
  102.  
  103.         }
  104.     }
  105.  
  106.     // 实现Runnable接口创建线程
  107.     static class NewRunnable implements Runnable {
  108.         @Override
  109.         public void run() {
  110.  
  111.             System.out.println("实现Runnable接口-3 = " + DateUtils.getNowTime());
  112.  
  113.             //等待
  114.             try {
  115.                 Thread.sleep(2000);
  116.             } catch (InterruptedException e) {
  117.                 throw new RuntimeException(e);
  118.             }
  119.             System.out.println("实现Runnable接口-4 = " + DateUtils.getNowTime());
  120.         }
  121.     }
  122.  
  123.     /**
  124.      * 实现Callable接口创建线程
  125.      * 是有返回值的线程调用
  126.      */
  127.     static class NewCallable implements Callable<String> {
  128.         @Override
  129.         public String call() throws Exception {
  130.             System.out.println("实现Callable接口创建线程-5 = " + DateUtils.getNowTime());
  131.             Thread.sleep(3000);
  132.             System.out.println("实现Callable接口创建线程-6 = " + DateUtils.getNowTime());
  133.             return "Callable接口创建线程";
  134.         }
  135.     }
  136.  
  137.     // 使用线程池创建线程
  138.     static class NewThreadPool {
  139.         public static void main(String[] args) {
  140.             // 创建大小2个任务的线程池
  141.             ExecutorService executorService = Executors.newFixedThreadPool(2);
  142.             // 提交任务
  143.             executorService.submit(new NewRunnable());
  144.             executorService.submit(new NewCallable());
  145.             // 关闭线程池
  146.             executorService.shutdown();
  147.         }
  148.     }
  149.  
  150.  
  151. }

声明：本文内容由网友自发贡献，不代表【wpsshop博客】立场，版权归原作者所有，本站不承担相应法律责任。如您发现有侵权的内容，请联系我们。转载请注明出处：https://www.wpsshop.cn/w/不正经/article/detail/323653
推荐阅读
相关标签

Copyright © 2003-2013 www.wpsshop.cn 版权所有，并保留所有权利。

  

闽ICP备14008679号