Bagaimana untuk melaksanakan multi-threading dalam java

1. Ungkapan Lambda mencipta benang

Gunakan borang lambda untuk membuat instantiate kelas tugas benang, mencipta objek benang dan lulus kelas tugas benang sebagai parameter pembina.

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. Gunakan ExecutorService, Callable dan Future untuk melaksanakan multi-threading yang mengembalikan hasil

Tugas yang boleh mengembalikan nilai mestilah antara muka Boleh Panggil, serupa, tidak Tugas yang mengembalikan nilai mestilah antara muka Runnable. Selepas melaksanakan tugas Boleh Dipanggil, anda boleh mendapatkan objek Masa Depan Dengan memanggil get, anda boleh mendapatkan Objek yang dikembalikan oleh tugas Boleh Dipanggil Kemudian digabungkan dengan antara muka kolam benang ExecutorService, anda boleh melaksanakan berbilang benang yang mengembalikan hasil.

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 + "毫秒】";
}
}

Atas ialah kandungan terperinci Bagaimana untuk melaksanakan multi-threading dalam java. Untuk maklumat lanjut, sila ikut artikel berkaitan lain di laman web China PHP!