Java创建多线程的几种方式

Wesley13
• 阅读 615

Java创建多线程的几种方式

[TOC]

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的几个构造方法
Java创建多线程的几种方式

执行定时器任务使用的是schedule方法:
Java创建多线程的几种方式

具体代码实现:

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

关注公众号:java宝典 Java创建多线程的几种方式

点赞
收藏
评论区
推荐文章
blmius blmius
3年前
MySQL:[Err] 1292 - Incorrect datetime value: ‘0000-00-00 00:00:00‘ for column ‘CREATE_TIME‘ at row 1
文章目录问题用navicat导入数据时,报错:原因这是因为当前的MySQL不支持datetime为0的情况。解决修改sql\mode:sql\mode:SQLMode定义了MySQL应支持的SQL语法、数据校验等,这样可以更容易地在不同的环境中使用MySQL。全局s
wanQQ wanQQ
2年前
Java学习 Day01 多线程
Java学习Day01多线程Java多线程实现方式有2种1.继承Thread类,重写run方法案例测试类Thread01Javapackagetop.wanqq.thread;/@authorwanqq/publicclassThread01extendsThread@Overridepubli
待兔 待兔
2个月前
手写Java HashMap源码
HashMap的使用教程HashMap的使用教程HashMap的使用教程HashMap的使用教程HashMap的使用教程22
Wesley13 Wesley13
2年前
java多线程实现的三种方式
JAVA多线程实现方式主要有三种:继承Thread类、实现Runnable接口、使用ExecutorService、Callable、Future实现有返回结果的多线程。其中前两种方式线程执行完后都没有返回值,只有最后一种是带返回值的。1、继承Thread类实现多线程继承Thread类的方法尽管被我列为一种多线程实现方式,但Thread本质上也是实现
浪人 浪人
3年前
一篇文章弄懂Java多线程基础和Java内存模型
文章目录一、多线程的生命周期及五种基本状态二、Java多线程的创建及启动1.继承Thread类,重写该类的run()方法2.通过实现Runnable接口创建线程类3.通过Callable和Future接口创建线程三、Java内存模型概念四、内存间的交互操作五、volatile和synchronized的
Wesley13 Wesley13
2年前
Java日期时间API系列31
  时间戳是指格林威治时间1970年01月01日00时00分00秒起至现在的总毫秒数,是所有时间的基础,其他时间可以通过时间戳转换得到。Java中本来已经有相关获取时间戳的方法,Java8后增加新的类Instant等专用于处理时间戳问题。 1获取时间戳的方法和性能对比1.1获取时间戳方法Java8以前
Stella981 Stella981
2年前
KVM调整cpu和内存
一.修改kvm虚拟机的配置1、virsheditcentos7找到“memory”和“vcpu”标签,将<namecentos7</name<uuid2220a6d1a36a4fbb8523e078b3dfe795</uuid
Wesley13 Wesley13
2年前
00:Java简单了解
浅谈Java之概述Java是SUN(StanfordUniversityNetwork),斯坦福大学网络公司)1995年推出的一门高级编程语言。Java是一种面向Internet的编程语言。随着Java技术在web方面的不断成熟,已经成为Web应用程序的首选开发语言。Java是简单易学,完全面向对象,安全可靠,与平台无关的编程语言。
Wesley13 Wesley13
2年前
Java多线程学习笔记
Java中创建多线程的三种方法1、继承Thread类创建线程2、实现Runnable接口创建线程3、使用Callable和Future创建线程\
Wesley13 Wesley13
2年前
Java创建多线程的几种方式
Java创建多线程的几种方式\TOC\1、继承Thread类,重写run()方法//方式1packagecn.itcats.thread.Test1;publicclassDemo1extendsThread{