创建线程的三种方式:继承Thread、Runnable 接口、Callable 接口

简介: 创建线程的三种方式:继承Thread、Runnable 接口、Callable 接口

当在Java中创建线程时,有以下3种方法:

通过实现Runnable接口:

       这是Java中创建线程的推荐方式,因为它允许你分离线程的任务(run 方法)与线程的执行。以下是创建线程的步骤:

  • 创建一个实现Runnable接口的类,该接口包含一个run方法,这个方法将定义线程要执行的任务。
class MyRunnable implements Runnable {
    @Override
    public void run() {
        // 线程要执行的任务
        System.out.println("线程执行了任务");
    }
}
  • 创建一个Thread对象,将Runnable实例传递给它,并调用start方法启动线程。
MyRunnable myRunnable = new MyRunnable();
Thread thread = new Thread(myRunnable);
thread.start();
  • 这会创建一个新的线程并执行run方法中定义的任务。

通过继承Thread类:

       这是另一种创建线程的方式,但通常不被推荐,因为它将线程的任务和线程本身耦合在一起。以下是创建线程的步骤:

  • 创建一个继承自Thread类的子类,并覆盖run方法,定义线程要执行的任务。
class MyThread extends Thread {
    @Override
    public void run() {
        // 线程要执行的任务
        System.out.println("线程执行了任务");
    }
}
  • 创建子类的实例,并调用start方法以启动线程。
MyThread myThread = new MyThread();
myThread.start();
  • 这将创建一个新的线程并执行run方法中定义的任务。

       无论你是选择实现Runnable接口还是继承Thread类,都需要明确指定线程要执行的任务,并在run方法中编写相应的代码。通常情况下,使用Runnable接口是更灵活和推荐的方式,因为它允许你将相同的任务传递给多个线程,而继承Thread类可能会导致类的单继承限制问题。

Callable 接口是 Java 中用于支持多线程编程的另一个关键接口。

       与 Runnable 相比,Callable 具有一些附加功能,主要是它允许线程返回一个值或抛出异常。这对于需要获取线程执行结果或者处理可能抛出异常的任务非常有用。

  • Callable 接口: Callable 接口定义了一个名为 call 的方法,该方法在线程执行时返回一个结果或抛出异常。这个接口在 java.util.concurrent 包中定义。
  • Future 接口: 通常,当你使用 Callable 时,你会得到一个 Future 对象,它代表了异步计算的结果。Future 允许你在需要时获取线程的返回值,或者等待线程的执行完成。
  • ExecutorService 为了执行 Callable 对象,通常会使用 ExecutorService 接口,它是线程池的一种实现。ExecutorService 允许你提交 Callable 任务并管理线程的执行。

下面是一个Callable接口创建线程示例:

import java.util.concurrent.Callable;
import java.util.concurrent.Executors;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Future;
public class CallableExample {
    public static void main(String[] args) {
        // 创建一个 ExecutorService,通常使用它来管理线程池
        ExecutorService executorService = Executors.newFixedThreadPool(2);
        // 创建一个 Callable 任务
        Callable<String> task = new MyCallable();
        // 提交 Callable 任务给 ExecutorService,获取 Future 对象
        Future<String> future = executorService.submit(task);
        try {
            // 阻塞并等待任务执行完成,并获取结果
            String result = future.get();
            System.out.println("Callable任务的结果: " + result);
        } catch (Exception e) {
            e.printStackTrace();
        }
        // 关闭 ExecutorService
        executorService.shutdown();
    }
}
class MyCallable implements Callable<String> {
    @Override
    public String call() throws Exception {
        // 模拟一个耗时操作
        Thread.sleep(2000);
        return "Callable 任务已完成";
    }
}

使用 Callable 的主要优点包括:

  • 可以返回线程执行的结果,这在需要处理线程结果的情况下非常有用。
  • 可以抛出受检异常,允许更灵活地处理错误情况。
  • 可以使用 Future 对象跟踪线程的执行状态和结果。

此外,Java还提供了线程池的概念,可以更好地管理线程的生命周期和资源。

线程池用法示例:http://t.csdnimg.cn/TWyr9

相关文章
|
25天前
|
Java C# Python
线程等待(Thread Sleep)
线程等待是多线程编程中的一种同步机制,通过暂停当前线程的执行,让出CPU时间给其他线程。常用于需要程序暂停或等待其他线程完成操作的场景。不同语言中实现方式各异,如Java的`Thread.sleep(1000)`、C#的`Thread.Sleep(1000)`和Python的`time.sleep(1)`。使用时需注意避免死锁,并考虑其对程序响应性的影响。
|
2月前
|
Java
在Java多线程编程中,实现Runnable接口通常优于继承Thread类
【10月更文挑战第20天】在Java多线程编程中,实现Runnable接口通常优于继承Thread类。原因包括:1) Java只支持单继承,实现接口不受此限制;2) Runnable接口便于代码复用和线程池管理;3) 分离任务与线程,提高灵活性。因此,实现Runnable接口是更佳选择。
51 2
|
2月前
|
Java
Java中多线程编程的基本概念和创建线程的两种主要方式:继承Thread类和实现Runnable接口
【10月更文挑战第20天】《JAVA多线程深度解析:线程的创建之路》介绍了Java中多线程编程的基本概念和创建线程的两种主要方式:继承Thread类和实现Runnable接口。文章详细讲解了每种方式的实现方法、优缺点及适用场景,帮助读者更好地理解和掌握多线程编程技术,为复杂任务的高效处理奠定基础。
38 2
|
7月前
|
存储 Java
高并发编程之多线程锁和Callable&Future 接口
高并发编程之多线程锁和Callable&Future 接口
87 1
|
4月前
|
并行计算 Java 大数据
Callable和Future
Callable和Future
|
7月前
|
Java
Java并发编程:理解并使用Future和Callable接口
【2月更文挑战第25天】 在Java中,多线程编程是一个重要的概念,它允许我们同时执行多个任务。然而,有时候我们需要等待一个或多个线程完成,然后才能继续执行其他任务。这就需要使用到Future和Callable接口。本文将深入探讨这两个接口的用法,以及它们如何帮助我们更好地管理多线程。
|
Java
ExecutorService、Callable、Future实现有返回结果的多线程原理解析
ExecutorService、Callable、Future实现有返回结果的多线程原理解析
80 0
|
存储 Java
并发编程系列教程(09) - Callable与Future模式
并发编程系列教程(09) - Callable与Future模式
58 0
【并发技术11】Callable与Future的应用
【并发技术11】Callable与Future的应用
|
存储 Java
高并发编程之多线程锁和Callable&Future 接口
5 多线程锁 5.1 锁的八个问题演示 package com.xingchen.sync; import java.util.concurrent.TimeUnit; class Phone { public static synchronized void sendSMS() throws Exception { //停留4秒 TimeUnit.SECONDS.sleep(4); System.out.println("------sendSMS"); } public synchronized void
127 0