剑指offer之Runnable和Callable的区别

简介: 剑指offer之Runnable和Callable的区别

Runnable



Runnable接口非常简单,就定义了一个方法run(), 实现Runnable接口的run方法就可以实现多线程


// 函数式接口
@FunctionalInterface
public interface Runnable {
    public abstract void run();
}


Callable



很多人都知道要想在多线程中获取异步返回值结果一般是用Callable和FutureTask接口来配合实现,但可能很多人都不知道其实Callable是依赖于Runnable的run方法进行执行任务的,然后在通过FutureTask来收集返回值结果,下面咱们就自己模拟写一份FutureTask代码来看看是怎么实现的吧


 /**
 * @author yinfeng
 * @description  自己实现futureTask,基于park/unpark进行线程通讯
 * @since 2022/1/9 21:32
 */
public class MyFutureTask<T> implements Runnable {
     Callable<T> callable;
    /**
     * callable执行结果
     */
    T result;
    /**
     * task执行状态
     */
    String state = "new";
    /**
     * 存储正在等待的消费者
     */
    LinkedBlockingQueue<Thread> waiters = new LinkedBlockingQueue<>();
    public MyFutureTask(Callable<T> callable) {
        this.callable = callable;
    }
    @Override
    public void run() {
        try {
            result = callable.call();
        } catch (Exception e) {
            e.printStackTrace();
        } finally {
            state = "end";
        }
        // 任务执行完成后通过unpark通知消费者
        System.out.println(Thread.currentThread().getName() + " 生产者执行结束,通知消费者");
        while (true) {
            Thread waiter = waiters.poll();
            if (waiter == null) {
                break;
            }
            LockSupport.unpark(waiter);
        }
    }
    /**
     * park / unpark
     */
    public T get() throws Exception {
        Thread mainThread = Thread.currentThread();
        // 塞入等待的集合中
        waiters.add(mainThread); 
        // 判断状态
        System.out.println(Thread.currentThread().getName() + " 消费者进入等待");
        while (!"end".equals(state)) {
          // 阻塞等待任务执行完成后通知
            LockSupport.park(mainThread);
        }
        return result;
    }
}


我们写个demo测试一下


/**
 * @author yinfeng
 * @description
 * @since 2022/1/9 21:32
 */
public class FutureTaskTest {
    public static void main(String[] args) throws Exception {
        final MyFutureTask<String> futureTask = new MyFutureTask<>(() -> {
            Thread.sleep(5000);
            return "任务完成888";
        });
        new Thread(futureTask).start();
        final String result = futureTask.get();
        System.out.println("结果:"+result);
        // 控制台打印如下: 
        // main 消费者进入等待
    // Thread-0 生产者执行结束,通知消费者
    // 结果:任务完成888
    }
}


可以看到我们的demo也是正常运行的,所以很关键的一点还是Callable是依赖于Runnable的run方法进行执行任务的



目录
打赏
0
0
0
0
4
分享
相关文章
|
6月前
|
Java中Runnable和Callable有什么不同
【8月更文挑战第9天】Java中Runnable和Callable有什么不同
32 1
(八)深入并发之Runnable、Callable、FutureTask及CompletableFuture原理分析
关于Runnable、Callable接口大家可能在最开始学习Java多线程编程时,都曾学习过一个概念:在Java中创建多线程的方式有三种:继承Thread类、实现Runnable接口以及实现Callable接口。但是实则不然,真正创建多线程的方式只有一种:继承Thread类,因为只有`new Thread().start()`这种方式才能真正的映射一条OS的内核线程执行,而关于实现Runnable接口以及实现Callable接口创建出的Runnable、Callable对象在我看来只能姑且被称为“多线程任务”,因为无论是Runnable对象还是Callable对象,最终执行都要交由Threa
161 1
|
9月前
面试官:除了继承Thread类和实现Runnable接口,你知道使用Callable接口的方式来创建线程吗?
面试官:除了继承Thread类和实现Runnable接口,你知道使用Callable接口的方式来创建线程吗?
56 0
面试官:除了继承Thread类和实现Runnable接口,你知道使用Callable接口的方式来创建线程吗?
|
9月前
|
多线程(CAS, ABA问题, Runnable & Callable & 僵尸线程 & 孤儿进程)
多线程(CAS, ABA问题, Runnable & Callable & 僵尸线程 & 孤儿进程)
86 1
创建线程的三种方式:继承Thread、Runnable 接口、Callable 接口
创建线程的三种方式:继承Thread、Runnable 接口、Callable 接口
runnable 和 callable 有什么区别
runnable 和 callable 有什么区别
线程的创建、Lambda函数式接口?Runnable和Callable之间的适配?动态修改线程任务?这里带你图解Java线程池
上面只是提到了对于Thread执行任务的一种动态实现方法,肯定还有其他的。 那么动态实现有什么好处呢? 当我们有很多个任务的时候,我们如果一直使用new,再让gc的话,那么对于系统资源的消耗无疑是巨大的。 那么这个时候,如果我们固定一下,专门拿几个线程来处理并发任务呢?但是当并发任务很多又该怎么办? 这个时候就引入了池化思想 —— Pool 什么是池? 在学JDBC的时候我们知道了连接池,在学Spring的时候,我们又接触到了对象池。 其实按理来说线程池应该是大家在初学JavaSE的时候应该就遇到的,这里我们再来讲一下。 线程池,就是用一个容器来管理线程,这个容器叫做池(Poo
127 0
线程的创建、Lambda函数式接口?Runnable和Callable之间的适配?动态修改线程任务?这里带你图解Java线程池
|
9月前
|
高并发编程之多线程锁和Callable&Future 接口
高并发编程之多线程锁和Callable&Future 接口
111 1
Java社招面试中的高频考点:Callable、Future与FutureTask详解
大家好,我是小米。本文主要讲解Java多线程编程中的三个重要概念:Callable、Future和FutureTask。它们在实际开发中帮助我们更灵活、高效地处理多线程任务,尤其适合社招面试场景。通过 Callable 可以定义有返回值且可能抛出异常的任务;Future 用于获取任务结果并提供取消和检查状态的功能;FutureTask 则结合了两者的优势,既可执行任务又可获取结果。掌握这些知识不仅能提升你的编程能力,还能让你在面试中脱颖而出。文中结合实例详细介绍了这三个概念的使用方法及其区别与联系。希望对大家有所帮助!
174 60