java中的runnable关键字用途 Runnable接口的3个实现技巧

runnable接口Thread类协同工作的核心机制是:将实现runnable接口的任务对象传递给thread类构造函数,再通过start()方法启动线程。1. runnable接口定义任务逻辑,通过run()方法实现;2. thread类负责执行任务,需将runnable对象传入其构造函数;3. 调用thread对象的start()方法启动线程,触发runnable的run()方法执行。例如:创建myrunnable类实现runnable接口并重写run(),在main类中实例化myrunnable对象,并将其作为参数传入thread构造函数,最后调用thread.start()启动线程。

java中的runnable关键字用途 Runnable接口的3个实现技巧

Runnable 接口在 Java 中主要用于实现多线程,它允许你定义一个任务,然后让一个线程去执行这个任务,而不需要继承 Thread 类。这在需要继承其他类的情况下尤其有用,因为 Java 不支持多重继承

java中的runnable关键字用途 Runnable接口的3个实现技巧

Runnable 接口的核心作用就是解耦任务的定义和执行,你可以将任务逻辑封装在 Runnable 实现类中,然后将这个 Runnable 对象传递给 Thread 对象来执行。

java中的runnable关键字用途 Runnable接口的3个实现技巧

实现 Runnable 接口,你可以更灵活地控制线程的创建和管理,避免了直接继承 Thread 类带来的局限性。

立即学习Java免费学习笔记(深入)”;

java中的runnable关键字用途 Runnable接口的3个实现技巧

Runnable 接口如何与Thread类协同工作?

Runnable 接口本身只是定义了一个 run() 方法,你需要将实现了 Runnable 接口的对象传递给 Thread 类的构造函数,然后调用 Thread 对象的 start() 方法来启动线程。

public class MyRunnable implements Runnable {     @Override     public void run() {         System.out.println("线程正在执行...");     } }  public class Main {     public static void main(String[] args) {         MyRunnable myRunnable = new MyRunnable();         Thread thread = new Thread(myRunnable);         thread.start();     } }

在这个例子中,MyRunnable 类实现了 Runnable 接口,并重写了 run() 方法。在 Main 类中,我们创建了一个 MyRunnable 对象,并将其传递给 Thread 类的构造函数。然后,我们调用 thread.start() 方法来启动线程。

Runnable 接口的3个实现技巧

  1. 使用 Lambda 表达式简化 Runnable 实现

Java 8 引入了 Lambda 表达式,可以更简洁地实现 Runnable 接口。如果你的 Runnable 实现非常简单,可以使用 Lambda 表达式来代替传统的匿名内部类。

Thread thread = new Thread(() -> {     System.out.println("线程正在执行..."); }); thread.start();

Lambda 表达式让代码更简洁易读,特别是在处理简单的任务时。

  1. 利用 ExecutorService 管理线程池

直接创建和管理线程可能会导致资源浪费和性能问题。使用 ExecutorService 可以更有效地管理线程池,它可以重用线程,避免频繁创建和销毁线程的开销。

import java.util.concurrent.ExecutorService; import java.util.concurrent.Executors;  public class Main {     public static void main(String[] args) {         ExecutorService executor = Executors.newFixedThreadPool(5); // 创建一个固定大小的线程池          for (int i = 0; i < 10; i++) {             int taskNumber = i;             executor.execute(() -> {                 System.out.println("线程 " + Thread.currentThread().getName() + " 正在执行任务 " + taskNumber);             });         }          executor.shutdown(); // 关闭线程池     } }

在这个例子中,我们创建了一个固定大小为 5 的线程池,然后提交了 10 个任务给线程池。ExecutorService 会自动分配线程来执行这些任务,并在任务完成后重用线程。

  1. 结合 Future 接口获取线程执行结果

Runnable 接口的 run() 方法没有返回值。如果需要获取线程执行的结果,可以结合 Future 接口使用。Future 接口提供了 get() 方法,可以阻塞等待线程执行完成并获取结果。

import java.util.concurrent.*;  public class Main {     public static void main(String[] args) throws ExecutionException, InterruptedException {         ExecutorService executor = Executors.newSingleThreadExecutor();          Callable<String> task = () -> {             Thread.sleep(1000); // 模拟耗时操作             return "线程执行完成";         };          Future<String> future = executor.submit(task);          System.out.println("等待线程执行结果...");         String result = future.get(); // 阻塞等待线程执行完成          System.out.println("线程执行结果:" + result);          executor.shutdown();     } }

在这个例子中,我们使用了 Callable 接口,它类似于 Runnable 接口,但 call() 方法可以返回一个值。我们使用 ExecutorService 提交 Callable 任务,并获取 Future 对象。然后,我们调用 future.get() 方法来等待线程执行完成并获取结果。

Runnable 和 Thread 的选择:什么时候应该使用哪个?

如果你的类需要继承其他类,那么只能选择实现 Runnable 接口。如果你的类不需要继承其他类,并且希望直接控制线程的行为,那么可以选择继承 Thread 类。但通常情况下,推荐使用 Runnable 接口,因为它更灵活,更符合面向对象的设计原则。

如何处理 Runnable 接口中的异常?

Runnable 接口的 run() 方法不能抛出受检异常(checked exception)。如果 run() 方法中可能会抛出受检异常,你需要使用 try-catch 块来捕获并处理这些异常。

public class MyRunnable implements Runnable {     @Override     public void run() {         try {             // 可能会抛出受检异常的代码             Thread.sleep(1000);         } catch (InterruptedException e) {             e.printStackTrace();         }     } }

如果 run() 方法中抛出了未受检异常(unchecked exception),那么线程会终止,并且异常会传播到调用线程的 uncaughtExceptionHandler 中。你可以设置 uncaughtExceptionHandler 来处理这些未受检异常。

© 版权声明
THE END
喜欢就支持一下吧
点赞5 分享