江苏龙网

  1. 主页 > 生活百科 > >

深入浅出、玩转Java多线程( 三 )

java多线程

  • 在任务完成后，可以通过调用Future对象的get()方法获取任务的执行结果，并打印输出 。
  • 最后调用ExecutorService的shutdown()方法关闭线程池，应该在所有任务执行完成后才能关闭线程池 。
    • 注意，在使用Callable实现多线程时，要考虑线程安全、同步机制、任务调度和管理等问题，以确保程序的正确性和稳定性 。
    同时，由于Callable任务的执行时间可能会比较长，可以设置超时时间来避免任务执行时间过长导致的程序阻塞 。
    Future实现多线程Future是Java中的一个接口，用于异步获取任务执行结果 。
    在多线程编程中，可以使用Future来获取异步任务的执行结果，以便在任务完成后进行处理或展示 。
    使用Future实现多线程，需要以下步骤：
    1. 创建一个实现了Callable接口的类，实现call()方法，并在方法中编写线程执行的代码 。
    2. 创建一个ExecutorService对象，可以使用Executors类提供的静态方法创建线程池，如newFixedThreadPool()、newCachedThreadPool()、newSingleThreadExecutor()等 。
    3. 将Callable对象提交给ExecutorService对象执行，可以使用submit()方法提交，submit()方法会返回一个Future对象 。
    4. 调用Future对象的get()方法获取Callable线程执行的结果 。如果任务还没有执行完成，get()方法会阻塞当前线程直到任务执行完成并返回结果 。
    import java.util.ArrayList;import java.util.List;import java.util.concurrent.*; public class FutureDemo {public static void main(String[] args) throws Exception {// 创建一个线程池ExecutorService executor = Executors.newFixedThreadPool(10);// 提交10个Callable任务给线程池执行List<Future<Integer>> results = new ArrayList<>();for (int i = 0; i < 10; i++) {Callable<Integer> task = new MyTask(i);Future<Integer> result = executor.submit(task);results.add(result);}// 输出Callable任务的执行结果for (int i = 0; i < 10; i++) {Integer result = results.get(i).get();System.out.println("Task " + i + " result is " + result);}// 关闭线程池executor.shutdown();}} class MyTask implements Callable<Integer> {private int id;public MyTask(int id) {this.id = id;}public Integer call() throws Exception {System.out.println("Task " + id + " is running");Thread.sleep(1000);// 模拟任务执行时间return id * 10;}}在以上示例中:
    1. 首先创建了一个线程池，然后提交10个Callable任务给线程池执行 。每个Callable任务都是MyTask类的实例，MyTask类实现了Callable接口，并重写了call()方法，在方法中模拟了一个需要执行1秒钟的任务，并返回一个结果 。
    2. 在main函数中，使用List记录每个Callable任务的执行结果的Future对象，并在任务完成后通过调用get()方法获取Callable任务的执行结果 。如果任务还没有执行完成，get()方法会阻塞当前线程直到任务执行完成并返回结果 。
    3. 最后关闭线程池 。
    线程池实现多线程线程池是Java中提供的一个用于管理和复用多个线程的框架，可以有效地提高多线程应用程序的性能和可靠性 。
    使用线程池实现多线程，通常需要以下步骤：
    1. 创建一个线程池，可以使用Executors类提供的静态方法创建线程池，如newFixedThreadPool()、newCachedThreadPool()、newSingleThreadExecutor()等 。
    2. 创建一个实现了Runnable接口或Callable接口的类，实现run()方法或call()方法，并在方法中编写线程执行的代码 。
    3. 将Runnable对象或Callable对象提交给线程池执行，可以使用submit()方法提交，submit()方法会返回一个Future对象 。
    4. 关闭线程池，可以调用shutdown()方法或shutdownNow()方法 。
    import java.util.ArrayList;import java.util.List;import java.util.concurrent.*; public class ThreadPoolDemo {public static void main(String[] args) throws Exception {// 创建一个包含10个线程的线程池ExecutorService executor = Executors.newFixedThreadPool(10);// 提交10个任务给线程池执行，并记录每个任务的执行结果List<Future<Integer>> results = new ArrayList<>();for (int i = 0; i < 10; i++) {Callable<Integer> task = new MyTask(i);Future<Integer> result = executor.submit(task);results.add(result);}// 等待所有任务执行完成executor.shutdown();executor.awaitTermination(Long.MAX_VALUE, TimeUnit.SECONDS);// 输出所有任务的执行结果int total = 0;for (int i = 0; i < 10; i++) {try {Integer result = results.get(i).get();System.out.println("Task " + i + " result is " + result);total += result;} catch (InterruptedException e) {e.printStackTrace();} catch (ExecutionException e) {System.out.println("Task " + i + " execution error: " + e.getCause().getMessage());}}System.out.println("Total result is " + total);}} class MyTask implements Callable<Integer> {private int id;public MyTask(int id) {this.id = id;}public Integer call() throws Exception {System.out.println("Task " + id + " is running");Thread.sleep(2000);// 模拟任务执行时间if (id % 2 == 0) {throw new RuntimeException("Task " + id + " execution error");}return id * 10;}}


    推荐阅读


    上一篇：从Sysstat到Metric：数据库可观测性的巨大进步

    下一篇：详解Tomcat配置参数connectionTimeout意义