• 技术文章 >java >java基础

    java多线程有几种实现方法

    小妮浅浅小妮浅浅2021-04-20 09:45:11原创4810

    本教程操作环境:windows7系统、java10版,DELL G3电脑。

    1、lambda表达式创建线程

    使用lambda的形式实例化线程任务类,创建线程对象,并将线程任务类作为构造方法参数传入。

    package com.kingh.thread.create;
     
    /**
     * 创建线程with lambda
     *
     * @author <a href="https://blog.csdn.net/king_kgh>Kingh</a>
     * @version 1.0
     * @date 2019/3/18 10:04
     */
    public class CreateThreadDemo5_Lambda {
     
        public static void main(String[] args) throws Exception {
            // 使用lambda的形式实例化线程任务类
            Runnable task = () -> {
                while (true) {
                    // 输出线程的名字
                    printThreadInfo();
                }
            };
     
            // 创建线程对象,并将线程任务类作为构造方法参数传入
            new Thread(task).start();
     
            // 主线程的任务,为了演示多个线程一起执行
            while (true) {
                printThreadInfo();
                Thread.sleep(1000);
            }
        }
     
        /**
         * 输出当前线程的信息
         */
        private static void printThreadInfo() {
            System.out.println("当前运行的线程名为: " + Thread.currentThread().getName());
            try {
                Thread.sleep(1000);
            } catch (Exception e) {
                throw new RuntimeException(e);
            }
        }
    }

    2、使用ExecutorService、Callable、Future实现有返回结果的多线程

    可以返回值的任务必须是Callable接口,类似的,没有返回值的任务必须是Runnable接口。执行Callable任务后,可以获得一个Future对象,通过调用get可以获得Callable任务返回的Object,然后结合线程池接口ExecutorService可以实现传说中有返回结果的多线程。

    import java.util.concurrent.*;
    import java.util.Date;
    import java.util.List;
    import java.util.ArrayList;
     
    /**
    * 有返回值的线程
    */
    @SuppressWarnings("unchecked")
    public class Test {
    public static void main(String[] args) throws ExecutionException,
        InterruptedException {
       System.out.println("----程序开始运行----");
       Date date1 = new Date();
     
       int taskSize = 5;
       // 创建一个线程池
       ExecutorService pool = Executors.newFixedThreadPool(taskSize);
       // 创建多个有返回值的任务
       List<Future> list = new ArrayList<Future>();
       for (int i = 0; i < taskSize; i++) {
        Callable c = new MyCallable(i + " ");
        // 执行任务并获取Future对象
        Future f = pool.submit(c);
        // System.out.println(">>>" + f.get().toString());
        list.add(f);
       }
       // 关闭线程池
       pool.shutdown();
     
       // 获取所有并发任务的运行结果
       for (Future f : list) {
        // 从Future对象上获取任务的返回值,并输出到控制台
        System.out.println(">>>" + f.get().toString());
       }
     
       Date date2 = new Date();
       System.out.println("----程序结束运行----,程序运行时间【"
         + (date2.getTime() - date1.getTime()) + "毫秒】");
    }
    }
     
    class MyCallable implements Callable<Object> {
    private String taskNum;
     
    MyCallable(String taskNum) {
       this.taskNum = taskNum;
    }
     
    public Object call() throws Exception {
       System.out.println(">>>" + taskNum + "任务启动");
       Date dateTmp1 = new Date();
       Thread.sleep(1000);
       Date dateTmp2 = new Date();
       long time = dateTmp2.getTime() - dateTmp1.getTime();
       System.out.println(">>>" + taskNum + "任务终止");
       return taskNum + "任务返回运行结果,当前任务时间【" + time + "毫秒】";
    }
    }

    以上就是java多线程有2种实现方法,本篇主要通过lambda表达式和Executor中的类,对多线程的功能进行实现。大家对这些不太常见的多线程实现方法,可以进行简单的了解。更多编程基础知识学习:python学习网

    专题推荐:java多线程
    品易云
    上一篇:java一次生成多个随机数出来 下一篇:java多线程原理

    相关文章推荐

    • 分页处理java多线程的数据• java多线程中的回调运用• java多线程中执行多个程序

    全部评论我要评论

    © 2021 Python学习网 苏ICP备2021003149号-1

  • 取消发布评论
  • 

    Python学习网