扫码关注官方微信

扫码下载APP
返回顶部
首页 > 资讯 > 后端开发 > Python >Java创建多线程的8种方式集合
  • 495

0
分享到

Java创建多线程的8种方式集合

2024-04-02 19:04:59 495人浏览 八月长安

Python 官方文档：入门教程 => 点击学习

摘要

目录1、继承Thread类，重写run()方法2、实现Runnable接口，重写run()3、匿名内部类的方式4、带返回值的线程(实现implements Callable<返

1、继承Thread类，重写run()方法


//方式1
package cn.itcats.thread.Test1; 
public class Demo1 extends Thread{
 
    //重写的是父类Thread的run()
 public void run() {
  System.out.println(getName()+"is running...");
 }  
 public static void main(String[] args) {
  Demo1 demo1 = new Demo1();
  Demo1 demo2 = new Demo1();
  demo1.start();
  demo2.start();
 }
}

2、实现Runnable接口，重写run()

实现Runnable接口只是完成了线程任务的编写

若要启动线程，需要new Thread(Runnable target)，再有thread对象调用start()方法启动线程

此处我们只是重写了Runnable接口的Run()方法，并未重写Thread类的run()，让我们看看Thread类run()的实现

本质上也是调用了我们传进去的Runnale target对象的run()方法


//Thread类源码中的run()方法
//target为Thread 成员变量中的 private Runnable target;
 
 @Override
    public void run() {
        if (target != null) {
            target.run();
        }
    }

所以第二种创建线程的实现代码如下：


package cn.itcats.thread.Test1; 

public class Demo2 implements Runnable{
 
    //重写的是Runnable接口的run()
 public void run() {
   System.out.println("implements Runnable is running");
 } 
 public static void main(String[] args) {
  Thread thread1 = new Thread(new Demo2());
  Thread thread2 = new Thread(new Demo2());
  thread1.start();
  thread2.start();
 } 
}

实现Runnable接口相比第一种继承Thread类的方式，使用了面向接口，将任务与线程进行分离，有利于解耦

3、匿名内部类的方式

适用于创建启动线程次数较少的环境，书写更加简便

具体代码实现：


package cn.itcats.thread.Test1;

public class Demo3 {
 public static void main(String[] args) {
  //方式1：相当于继承了Thread类，作为子类重写run()实现
  new Thread() {
   public void run() {
    System.out.println("匿名内部类创建线程方式1...");
   };
  }.start();  
    
  //方式2:实现Runnable,Runnable作为匿名内部类
  new Thread(new Runnable() {
   public void run() {
    System.out.println("匿名内部类创建线程方式2...");
   }
  } ).start();
 }
}

4、带返回值的线程(实现implements Callable<返回值类型>)

以上两种方式，都没有返回值且都无法抛出异常。

Callable和Runnbale一样代表着任务，只是Callable接口中不是run()，而是call()方法，但两者相似，即都表示执行任务，call()方法的返回值类型即为Callable接口的泛型

具体代码实现：


package cn.itcats.thread.Test1; 
import java.util.concurrent.Callable;
import java.util.concurrent.ExecutionException;
import java.util.concurrent.Future;
import java.util.concurrent.FutureTask;
import java.util.concurrent.RunnableFuture;
 

public class Demo5 implements Callable<String>{ 
 public String call() throws Exception {
  System.out.println("正在执行新建线程任务");
  Thread.sleep(2000);
  return "新建线程睡了2s后返回执行结果";
 }
 
 public static void main(String[] args) throws InterruptedException, ExecutionException {
  Demo5 d = new Demo5();
  
  FutureTask<String> task = new FutureTask<>(d);
  Thread t = new Thread(task);
  t.start();
  System.out.println("提前完成任务...");
  //获取任务执行后返回的结果
  String result = task.get();
  System.out.println("线程执行结果为"+result);
 } 
}

5、定时器(java.util.Timer)

关于Timmer的几个构造方法

执行定时器任务使用的是schedule方法：

具体代码实现：


package cn.itcats.thread.Test1; 
import java.util.Timer;
import java.util.TimerTask;
 

public class Demo6 {
	public static void main(String[] args) {
		Timer timer = new Timer();
		timer.schedule(new TimerTask() {
			@Override
			public void run() {
				System.out.println("定时任务延迟0(即立刻执行),每隔1000ms执行一次");
			}
		}, 0, 1000);
	}	
}

我们发现Timer有不可控的缺点，当任务未执行完毕或我们每次想执行不同任务时候，实现起来比较麻烦。这里推荐一个比较优秀的开源作业调度框架“quartz”，在后期我可能会写一篇关于quartz的博文。

6、线程池的实现(java.util.concurrent.Executor接口)

降低了创建线程和销毁线程时间开销和资源浪费

具体代码实现：


package cn.itcats.thread.Test1; 
import java.util.concurrent.Executor;
import java.util.concurrent.Executors; 
public class Demo7 {
 public static void main(String[] args) {
  //创建带有5个线程的线程池
  //返回的实际上是ExecutorService,而ExecutorService是Executor的子接口
  Executor threadPool = Executors.newFixedThreadPool(5);
  for(int i = 0 ;i < 10 ; i++) {
   threadPool.execute(new Runnable() {
    public void run() {
     System.out.println(Thread.currentThread().getName()+" is running");
    }
   });
  }  
 }
}

运行结果：

pool-1-thread-3 is running

pool-1-thread-1 is running

pool-1-thread-4 is running

pool-1-thread-3 is running

pool-1-thread-5 is running

pool-1-thread-2 is running

pool-1-thread-5 is running

pool-1-thread-3 is running

pool-1-thread-1 is running

pool-1-thread-4 is running

运行完毕，但程序并未停止，原因是线程池并未销毁，若想销毁调用threadPool.shutdown(); 注意需要把我上面的


Executor threadPool = Executors.newFixedThreadPool(10);

改为


ExecutorService threadPool = Executors.newFixedThreadPool(10);

否则无shutdown()方法

若创建的是CachedThreadPool则不需要指定线程数量，线程数量多少取决于线程任务，不够用则创建线程，够用则回收。

7、Lambda表达式的实现(parallelStream)


package cn.itcats.thread.Test1; 
import java.util.ArrayList;
import java.util.Arrays;
import java.util.List;
 

public class Demo8 {
 public static void main(String[] args) {
  List<Integer> list = Arrays.asList(1,2,3,4,5,6);
  Demo8 demo = new Demo8();
  int result = demo.add(list);
  System.out.println("计算后的结果为"+result);
 }
 
 public int add(List<Integer> list) {
  //若Lambda是串行执行,则应顺序打印
  list.parallelStream().forEach(System.out :: println);
  //Lambda有stream和parallelSteam(并行)
  return list.parallelStream().mapToInt(i -> i).sum();
 }
}

运行结果：

4
1
3
5
6
2

计算后的结果为21

事实证明是并行执行

8、Spring实现多线程

(1)新建Maven工程导入spring相关依赖

(2)新建一个java配置类(注意需要开启@EnableAsync注解——支持异步任务)


package cn.itcats.thread; 
import org.springframework.context.annotation.ComponentScan;
import org.springframework.context.annotation.Configuration;
import org.springframework.scheduling.annotation.EnableAsync;
 
@Configuration
@ComponentScan("cn.itcats.thread")
@EnableAsync
public class Config {
 
}

(3)书写异步执行的方法类(注意方法上需要有@Async——异步方法调用)


package cn.itcats.thread; 
import org.springframework.scheduling.annotation.Async;
import org.springframework.stereotype.Service;
 
@Service
public class AsyncService {
 
 @Async
 public void Async_A() {
  System.out.println("Async_A is running");
 }
 
 @Async
 public void Async_B() {
  System.out.println("Async_B is running");
 }
}

(4)创建运行类


package cn.itcats.thread; 
import org.springframework.context.annotation.AnnotationConfigApplicationContext; 
public class Run {
 public static void main(String[] args) {
  //构造方法传递Java配置类Config.class
  AnnotationConfigApplicationContext ac = new AnnotationConfigApplicationContext(Config.class);
  AsyncService bean = ac.getBean(AsyncService.class);
  bean.Async_A();
  bean.Async_B();
 }
}

以上为个人经验，希望能给大家一个参考，也希望大家多多支持编程网。

您可能感兴趣的文档:

--结束END--

本文标题: Java创建多线程的8种方式集合

本文链接: https://lsjlt.com/news/133465.html(转载时请注明来源链接)

有问题或投稿请发送至: 邮箱/279061341@qq.com    QQ/279061341

猜你喜欢
  • Java创建多线程的8种方式集合
    目录1、继承Thread类，重写run()方法2、实现Runnable接口，重写run()3、匿名内部类的方式4、带返回值的线程(实现implements Callable<返...
    99+
    2024-04-02
  • java创建多线程的七种方式
    一、继承Thread，重写run方法 通过自定义一个类（这里起名为：MyThread），继承Thread类，重写run方法，最后在main方法中new出MyThread实例，调用这个实例的继承的Thread类的start方法创建一个线程。 ...
    99+
    2023-09-26
    java
  • Java多线程的创建方式
    这篇文章主要介绍“Java多线程的创建方式”，在日常操作中，相信很多人在Java多线程的创建方式问题上存在疑惑，小编查阅了各式资料，整理出简单好用的操作方法，希望对大家解答”Java多线程的创建方式”的疑惑有所帮助！接下来，请跟着小编一起来...
    99+
    2023-06-20
  • Java线程的三种创建方式
    目录1、Thread2、Runnable和Thread3、Runnable和Thread4、三者对比5、注意项1、Thread 继承Thread类，并重写run方法 class ...
    99+
    2024-04-02
  • Java 中创建线程的几种方式
    Java 是一种面向对象的编程语言，它支持多线程编程。多线程编程是指在一个程序中同时运行多个线程，这些线程可以并行执行，以提高程序的效率和性能。Java 提供了多种创建线程的方法，本文将介绍这些方法以...
    99+
    2023-09-13
    java jvm servlet
  • Java线程创建的四种方式总结
    多线程的创建，方式一：继承于Thread类 1.创建一个继承于Thread类的子类 2.重写Thread类的run()--->将此线程执行的操作声明在run()中 3.创建Th...
    99+
    2024-04-02
  • java中创建线程有几种方式
    线程的创建方式继承Thread类实现多线程覆写Runnable()接口实现多线程，而后同样覆写run()。推荐此方式使用Callable和Future创建线程相关视频教程推荐：java学习视频实例如下：继承Thread类实现多线程 publ...
    99+
    2018-07-06
    java教程 java 线程 创建 方式
  • java创建多线程的方式有哪些
    Java创建多线程的方式有以下几种：1. 继承Thread类：创建一个类继承Thread类，并重写run()方法，然后创建该类的对象，调用start()方法启动线程。```javaclass MyThread extends Threa...
    99+
    2023-08-09
    java
  • 3种Java创建线程的方式和区别
    在java中如何创建线程？下面本篇文章给大家介绍3种创建线程的方式以及区别。有一定的参考价值，有需要的朋友可以参考一下，希望对大家有所帮助。在java中如果要创建线程的话，一般有3种方法：继承Thread类；实现Runnable接口；使用C...
    99+
    2017-09-19
    java入门 Java 线程
  • Java多线程中线程的两种创建方式及比较代码示例
    线程的概念：线程(thread)是指一个任务从头至尾的执行流，线程提供一个运行任务的机制，对于java而言，一个程序中可以并发的执行多个线程，这些线程可以在多处理器系统上同时运行。当程序作为一个应用程序运行时，java解释器为main()方...
    99+
    2023-05-30
    java 多线程 创建
  • Java的线程与进程以及线程的四种创建方式
    目录问题描述case 代码截图数据库DOcontroller定义dao定义mapper实现mysql相关 properties配置数据库数据测试结果具体错误信息解决总结问题描述 这里...
    99+
    2024-04-02
  • Java多线程的常用创建方式总结
    Java多线程的创建方式 Java现在有四种创建的方式：继承Threa类、实现Runnable接口、实现Callable接口、线程池 Thread、Runnable都在java.la...
    99+
    2024-04-02
  • java实现/创建线程的几种方式小结
    进程与线程 进程可以简单理解成一个可执行程序例如.exe，在Windows中的任务管理器中可以查看每一个进程，进程是一次程序的执行，是程序在数据集合上运行的过程，是系统资源调度的一...
    99+
    2024-04-02
  • 详解Java创建线程的五种常见方式
    目录Java中如何创建线程呢？1.显示继承Thread，重写run来指定现成的执行代码。2.匿名内部类继承Thread，重写run来执行线程执行的代码。3.显示实现Runnable接...
    99+
    2024-04-02
  • java创建线程池一共有七种方式
    java创建线程池一共有七种方式 这 7 种实现方法分别是： Executors.newFixedThreadPool：创建一个固定大小的线程池，可控制并发的线程数，超出的线程会在队列中等待。 Exe...
    99+
    2023-09-13
    java 开发语言
  • Java创建线程及配合使用Lambda方式
    目录一、创建线程三种方式1.1 继承Thread类创建线程类1.2 通过Runnable接口创建线程类使用Lambda表达式1.3 通过Callable和Future创建线程使用La...
    99+
    2024-04-02
  • java线程池的四种创建方式详细分析
    目录前言1. 线程池2. 创建方式前言 在讲述线程池的前提 先补充一下连接池的定义 连接池是创建和管理一个连接的缓冲池的技术，这些连接准备好被任何需要它们的线程使用 可以看到其连接池...
    99+
    2024-04-02
  • Java多线程之线程的创建
    目录一、三种创建方式二、通过Thread类创建2.1 步骤2.2 案例2.3 注意的问题三、Thread类中常用的方法3.1 案例四、通过实现Runnable接口来创建线程4.1 创...
    99+
    2024-04-02
  • Java创建线程的方式解析
    目录继承Thread，这里使用匿名内部类实现Runnable接口，配合Thread类，同样用匿名内部类FutureTask配合Thread继承Thread，这里使用匿名内部类 @Sl...
    99+
    2024-04-02
  • 很多人竟然不知道Java线程池的创建方式有7种
    目录前言什么是线程池？线程池使用1.FixedThreadPool2.CachedThreadPool3.SingleThreadExecutor4.ScheduledThreadP...
    99+
    2024-04-02
软考高级职称资格查询
热门wiki
近期文章
推荐阅读
热门问答
热门标签
编程网，编程工程师的家园，是目前国内优秀的开源技术社区之一，形成了由开源软件库、代码分享、资讯、协作翻译、讨论区和博客等几大频道内容，为IT开发者提供了一个发现、使用、并交流开源技术的平台。

  • 官方手机版

  • 微信公众号

  • 商务合作