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

目录
  • 1、继承Thread类,重写run()方法
  • 2、实现Runnable接口,重写run()
  • 3、匿名内部类的方式
  • 4、带返回值的线程(实现implements Callable<返回值类型>)
  • 5、定时器(java.util.Timer)
  • 6、线程池的实现(java.util.concurrent.Executor接口)
  • 7、Lambda表达式的实现(parallelStream)
  • 8、Spring实现多线程

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;
/**
 * 第二种创建启动线程的方式
 * 实现Runnale接口
 * @author fatah
 */
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;
/**
 * 创建启动线程的第三种方式————匿名内部类
 * @author fatah
 */
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;

/**
 * 方式4:实现Callable<T> 接口
 * 含返回值且可抛出异常的线程创建启动方式
 * @author fatah
 */
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();
  /* call()只是线程任务,对线程任务进行封装
   class FutureTask<V> implements RunnableFuture<V>
   interface RunnableFuture<V> extends Runnable, Future<V>
  */
  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;

/**
 * 方法5:创建启动线程之Timer定时任务
 * @author fatah
 */
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;

/**
 * 使用Lambda表达式并行计算
 * parallelStream
 * @author fatah
 */
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();
 }
}

以上为个人经验,希望能给大家一个参考,也希望大家多多支持我们。

(0)

相关推荐

  • 一篇文中细看Java多线程的创建方式

    前言 Java现在有四种创建的方式:继承Threa类.实现Runnable接口.实现Callable接口.线程池 Thread.Runnable都在java.lang包下:Callable.线程池都在java.util.concurrent包下 1.继承Thread类,重写run方法 创建一个类继承Thread类,并重写run():因为run()是线程具体执行的方法. 在测试类或者main()创建Thread对象,并调用start()启动线程 备注:start()是启动线程,run()是线程执行

  • java多线程创建及线程安全详解

    什么是线程 线程被称为轻量级进程,是程序执行的最小单位,它是指在程序执行过程中,能够执行代码的一个执行单位.每个程序程序都至少有一个线程,也即是程序本身. 线程的状态 新建(New):创建后尚未启动的线程处于这种状态 运行(Runable):Runable包括了操作系统线程状态的Running和Ready,也就是处于此状态的线程有可能正在执行,也有可能正在等待着CPU为它分配执行时间. 等待(Wating):处于这种状态的线程不会被分配CPU执行时间.等待状态又分为无限期等待和有限期等待,处于无

  • Java创建多线程局域网聊天室实例

    局域网聊天室 在学习了一个学期的java以后,觉得java真是博大精深,彻底放弃了因为c++而轻视java的心态,搞了一个多线程的聊天室,熟悉了一下服务器和客户机的操作. 1.TCP 要实现局域网连接,就必须知道信息传输的原理. 在局域网里面传输的信息都是以包的形式,我使用的TCP包传输数据,TCP包里面封装了IP报文. 下面这句话就是通过一个静态IPV4协议的类得到一个服务器的IP地址. address = InetAddress.getByName("192.168.43.86")

  • 详解Java创建多线程的四种方式以及优缺点

    java有以下四种创建多线程的方式 1:继承Thread类创建线程 2:实现Runnable接口创建线程 3:使用Callable和FutureTask创建线程 4:使用线程池,例如用Executor框架创建线程 DEMO代码 package thread; import java.util.concurrent.*; public class ThreadTest { public static void main(String[] args) throws ExecutionExceptio

  • Java多线程之线程的创建

    一.三种创建方式 基于什么创建 创建的方式 Thread类 继承Thread类 Runnable接口 实现Runnable接口 callable接口 实现callable接口 二.通过Thread类创建 2.1 步骤 自定义线程类继承Thread类 重写run()方法,编写线程执行体(当成main()方法用) 创建线程对象,调用start()方法启动线程 2.2 案例 创建两个线程,其中一个线程打印100以内的偶数,另一个线程打印100以内的奇数 //主方法 public class Demo0

  • Java面试知识点总结

    目录 基础篇 一.JAVA: 二.JDK JRE JVM的区别: 三.java的基本数据类型 四.switch默认接受的几种数据类型 五.修饰符的作用 六.Static修饰符 七.final,finally,finalize 三者区别 八.StringBuffer StringBuilder String 区别 九.String的常用方法 十.Java面向对象的特征 十一.抽象类与接口的区别 十二.List,Set,Collection,Collections 十三.Io流 十四.java Ex

  • 详解在Java中如何创建多线程程序

    创建多线程程序的第一种方式:创建Thread类的子类 java.lang.Thread类:是描述线程的类,我们想要实现多线程程序,就必须继承Thread类 实现步骤: 1.创建一个Thread类的子类 2.在Thread类的子类中重写Thread类中的run方法,设置线程任务(开启线程要做什么?) 3.创建Thread类的子类对象 4.调用Thread类中的方法start方法,开启新的线程,执行run方法 void start()使该线程开始执行;Java虚拟机调用该线程的run方法. 结果是两

  • Java多线程的常用创建方式总结

    Java现在有四种创建的方式:继承Threa类.实现Runnable接口.实现Callable接口.线程池 Thread.Runnable都在java.lang包下:Callable.线程池都在java.util.concurrent包下 1.继承Thread类,重写run方法 创建一个类继承Thread类,并重写run():因为run()是线程具体执行的方法 在测试类或者main()创建Thread对象,并调用start()启动线程 备注:start()是启动线程,run()是线程执行的业务方

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

    目录 1.继承Thread类,重写run()方法 2.实现Runnable接口,重写run() 3.匿名内部类的方式 4.带返回值的线程(实现implements Callable<返回值类型>) 5.定时器(java.util.Timer) 6.线程池的实现(java.util.concurrent.Executor接口) 7.Lambda表达式的实现(parallelStream) 8.Spring实现多线程 1.继承Thread类,重写run()方法 //方式1 package cn.i

  • Java创建多线程的几种方式实现

    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 D

  • Java创建多线程的两种方式对比

    采用继承Thead类实现多线程: 优势:编写简单,如果需要访问当前线程,只需使用this即可,无需使用Thead.currentThread()方法. 劣势:因为这种线程类已经继承了Thead类,所以不能再继承其它类. 示例代码: 复制代码 代码如下: package org.frzh.thread;    public class FirstThread extends Thread{      private int i;           //重写run方法,run方法的方法体就是线程执

  • java实现多线程的两种方式继承Thread类和实现Runnable接口的方法

    实现方式和继承方式有什么区别呢? *区别: *继承Thread:线程代码存放在Thread子类run方法中 *实现Runnable:线程代码存放在接口的子类的run方法中 *实现方式的好处:避免了单继承的局限性 *在定义线程时,建议使用实现方式,当然如果一个类没有继承父类,那么也可以通过继承Thread类来实现多线程 *注意:Runnable接口没有抛出异常,那么实现它的类只能是try-catch不能throws *Java对多线程的安全问题提供了专业的解决方式就是同步代码块synchroniz

  • Java创建随机数的四种方式总结

    目录 c语言随机数 java 1.Random 2.SecureRandom 3.ThreadLocalRandom 4.Math.Random 完整代码 第一次接触到随机数还是在c语言里面 使用的是 rand(); 但是重新执行一次的时候会发现,诶,居然和上一次执行的结果是一样的,因为没有初始化种子,所以系统用的都是统一的种子这时就会出现每次产生的随机数都一样,这时就会使用到 srand();这个随机数的发生器, 把种子给定当前的时间 即 srand((unsigned) time (&t))

  • Java创建数组的几种方式总结

    1.一维数组的声明方式: type[] arrayName; 或 type arrayName[]; 附:推荐使用第一种格式,因为第一种格式具有更好的可读性,表示type[]是一种引用类型(数组)而不是type类型.建议不要使用第二种方式 下面是典型的声明数组的方式: // 声明整型数组 int[] intArray0 ; int intArray1 []; // 声明浮点型数组 float floatArray0 []; float[] floatArray1 ; // 声明布尔型数组 boo

  • 详解Java实现多线程的三种方式

    本文实例为大家分享了Java实现多线程的三种方式,供大家参考,具体内容如下 import java.util.concurrent.Callable; import java.util.concurrent.FutureTask; public class Main { public static void main(String[] args) { //方法一:继承Thread int i = 0; // for(; i < 100; i++){ // System.out.println(T

  • Java 实现多线程的几种方式汇总

    我们先来看段示例代码 import java.util.concurrent.Callable; import java.util.concurrent.FutureTask; public class Main { public static void main(String[] args) { //方法一:继承Thread int i = 0; // for(; i < 100; i++){ // System.out.println(Thread.currentThread().getNa

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

随机推荐