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

 更新时间:2020年10月27日 10:44:38   作者:liangtengyu  
这篇文章主要介绍了Java创建多线程的几种方式实现,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友们下面随着小编来一起学习学习吧

Java技术迷

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

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
//方式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()方法

1
2
3
4
5
6
7
8
9
//Thread类源码中的run()方法
//target为Thread 成员变量中的 private Runnable target;
 
 @Override
 public void run() {
  if (target != null) {
   target.run();
  }
 }

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

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
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、匿名内部类的方式

适用于创建启动线程次数较少的环境,书写更加简便
具体代码实现:

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
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接口的泛型
具体代码实现:

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
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方法:


具体代码实现:

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
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接口)

降低了创建线程和销毁线程时间开销和资源浪费
具体代码实现:

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
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)

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
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注解——支持异步任务)

1
2
3
4
5
6
7
8
9
10
11
12
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——异步方法调用)

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
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)创建运行类

1
2
3
4
5
6
7
8
9
10
11
12
13
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();
  }
}

到此这篇关于Java创建多线程的几种方式实现的文章就介绍到这了,更多相关Java创建多线程内容请搜索脚本之家以前的文章或继续浏览下面的相关文章希望大家以后多多支持脚本之家!

蓄力AI

微信公众号搜索 “ 脚本之家 ” ,选择关注

程序猿的那些事、送书等活动等着你

原文链接:https://segmentfault.com/a/1190000037615955

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。
如若内容造成侵权/违法违规/事实不符,请将相关资料发送至 reterry123@163.com 进行投诉反馈,一经查实,立即处理!

相关文章

  • SpringBoot整合MybatisPlus的教程详解

    SpringBoot整合MybatisPlus的教程详解

    这篇文章主要介绍了SpringBoot整合MybatisPlus的方法,本文通过实例代码给大家介绍的非常详细,对大家的学习或工作具有一定的参考借鉴价值,需要的朋友可以参考下
    2020-11-11
  • springboot整合Nginx实现负载均衡反向代理的方法详解

    springboot整合Nginx实现负载均衡反向代理的方法详解

    这篇文章主要给大家介绍了关于springboot整合Nginx实现负载均衡反向代理的相关资料,文中通过图文以及实例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友可以参考下
    2022-01-01
  • idea生成类注释和方法注释的正确方法(推荐)

    idea生成类注释和方法注释的正确方法(推荐)

    这篇文章主要介绍了idea生成类注释和方法注释的正确方法,本文给大家介绍的非常详细,对大家的学习或工作具有一定的参考借鉴价值,需要的朋友可以参考下
    2020-11-11
  • com.mysql.jdbc.Driver 和 com.mysql.cj.jdbc.Driver的区别及设定serverTimezone的方法

    com.mysql.jdbc.Driver 和 com.mysql.cj.jdbc.Driver的区

    这篇文章主要介绍了com.mysql.jdbc.Driver 和 com.mysql.cj.jdbc.Driver的区别以及设定serverTimezone的方法,本文给大家介绍的非常详细,对大家的学习或工作具有一定的参考借鉴价值,需要的朋友可以参考下
    2023-09-09
  • Java反射机制如何解决数据传值为空的问题

    Java反射机制如何解决数据传值为空的问题

    这篇文章主要介绍了Java反射机制如何解决数据传值为空的问题,具有很好的参考价值,希望对大家有所帮助。如有错误或未考虑完全的地方,望不吝赐教
    2022-03-03
  • Mybatis主配置文件的properties标签详解

    Mybatis主配置文件的properties标签详解

    这篇文章主要介绍了Mybatis主配置文件的properties标签,本文给大家介绍的非常详细,对大家的学习或工作具有一定的参考借鉴价值,需要的朋友可以参考下
    2020-08-08
  • FastJson对于JSON格式字符串、JSON对象及JavaBean之间的相互转换操作

    FastJson对于JSON格式字符串、JSON对象及JavaBean之间的相互转换操作

    这篇文章主要介绍了FastJson对于JSON格式字符串、JSON对象及JavaBean之间的相互转换,非常不错,具有参考借鉴价值,需要的朋友可以参考下
    2017-11-11
  • 教你如何使用Java实现WebSocket

    教你如何使用Java实现WebSocket

    这篇文章主要介绍了教你如何使用Java实现WebSocket问题,具有很好的参考价值,希望对大家有所帮助。如有错误或未考虑完全的地方,望不吝赐教
    2023-06-06
  • Keycloak各种配置及API的使用说明

    Keycloak各种配置及API的使用说明

    这篇文章主要介绍了Keycloak各种配置及API的使用说明,具有很好的参考价值,希望对大家有所帮助。如有错误或未考虑完全的地方,望不吝赐教
    2023-03-03
  • SpringBoot中Filter没有生效原因及解决方案

    SpringBoot中Filter没有生效原因及解决方案

    Servlet 三大组件 Servlet、Filter、Listener 在传统项目中需要在 web.xml 中进行相应的配置,这篇文章主要介绍了SpringBoot中Filter没有生效原因及解决方案,需要的朋友可以参考下
    2024-04-04

最新评论