java面試常問(wèn)的Runnable和Callable的區(qū)別

更新時(shí)間：2022年01月11日 16:04:31 作者：隱風(fēng)

大家好，本篇文章主要講的是java面試常問(wèn)的Runnable和Callable的區(qū)別，感興趣的同學(xué)趕快來(lái)看一看吧，對(duì)你有幫助的話記得收藏一下

Runnable

Runnable接口非常簡(jiǎn)單,就定義了一個(gè)方法run(), 實(shí)現(xiàn)Runnable接口的run方法就可以實(shí)現(xiàn)多線程

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

Callable

可能很多人都知道要想在多線程中獲取異步返回值結(jié)果一般是用Callable和FutureTask接口來(lái)實(shí)現(xiàn)，但可能很多人都不知道其實(shí)Callable是依賴(lài)于Runnable的run方法進(jìn)行執(zhí)行任務(wù)的，然后在通過(guò)FutureTask來(lái)收集返回值結(jié)果，下面咱們就自己模擬寫(xiě)一份FutureTask代碼來(lái)看看是怎么實(shí)現(xiàn)的吧。

 /**
 * @author yinfeng
 * @description  自己實(shí)現(xiàn)futureTask，基于park/unpark進(jìn)行線程通訊
 * @since 2022/1/9 21:32
 */
public class MyFutureTask<T> implements Runnable {
     Callable<T> callable;
    /**
     * callable執(zhí)行結(jié)果
     */
    T result;
    /**
     * task執(zhí)行狀態(tài)
     */
    String state = "new";
    /**
     * 存儲(chǔ)正在等待的消費(fèi)者
     */
    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";
        }

        // 任務(wù)執(zhí)行完成后通過(guò)unpark通知消費(fèi)者
        System.out.println(Thread.currentThread().getName() + " 生產(chǎn)者執(zhí)行結(jié)束，通知消費(fèi)者");
        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); 
        // 判斷狀態(tài)
        System.out.println(Thread.currentThread().getName() + " 消費(fèi)者進(jìn)入等待");
        while (!"end".equals(state)) {
        	// 阻塞等待任務(wù)執(zhí)行完成后通知
            LockSupport.park(mainThread);
        }
        return result;
    }
}

我們寫(xiě)個(gè)demo測(cè)試一下

/**
 * @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 "任務(wù)完成888";
        });
        new Thread(futureTask).start();
        final String result = futureTask.get();
        System.out.println("結(jié)果："+result);
        // 控制臺(tái)打印如下: 
        // main 消費(fèi)者進(jìn)入等待
		// Thread-0 生產(chǎn)者執(zhí)行結(jié)束，通知消費(fèi)者
		// 結(jié)果：任務(wù)完成888
    }
}

可以看到我們的demo也是正常運(yùn)行的，所以很關(guān)鍵的一點(diǎn)還是Callable是依賴(lài)于Runnable的run方法進(jìn)行執(zhí)行任務(wù)的

到此這篇關(guān)于java面試常問(wèn)的Runnable和Callable的區(qū)別的文章就介紹到這了,更多相關(guān)java Runnable和Callable區(qū)別內(nèi)容請(qǐng)搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家！

您可能感興趣的文章: