Runnable && Callable

    xiaoxiao2022-07-12  166

    Runnable是一种有很大局限性的抽象,虽然run()能写入到日志文件或者将其结果放入某个共享的数据结构,但它不能返回一个值或者抛出一个受检查的异常。

    public interface Runnable { public abstract void run(); }

    Callable是一种更好的抽象:它认为主入口点(即call())将返回一个值,并可能抛出一个异常。

    public interface Callable<V> { V call() throws Exception; }

    使用方式

    Runnable可以提交给一个线程,直接启动一个线程来执行

    Thread thread = new Thread(new Runnable() { @Override public void run() { ................ } }); thread.start();

    Callable通常利用ExecutorService的submit方法去启动call方法自执行任务,而ExecutorService的submit又返回一个Future类型的结果,因此Callable通常也与Future一起使用。

    ExecutorService executorService = Executors.newFixedThreadPool(10); Callable<String> stringCallable = new Callable<String>() { @Override public String call() throws Exception { return null; } }; Future<String> stringFuture = executorService.submit(stringCallable);

    OR

    FutureTask<String> future = new FutureTask<>(new Callable<String>() { @Override public String call() throws Exception { return null; } }); executorService.execute(future); String res = future.get(3, TimeUnit.SECONDS);

    Future && FutureTask

    Future是用来获取异步计算结果的。

    public interface Future<V> { boolean cancel(boolean mayInterruptIfRunning); boolean isCancelled(); boolean isDone(); V get() throws InterruptedException, ExecutionException; V get(long timeout, TimeUnit unit) throws InterruptedException, ExecutionException, TimeoutException; }

    FutureTask类实现了RunnableFuture接口,RunnableFuture继承了Future

    public class FutureTask<V> implements RunnableFuture<V> { } public interface RunnableFuture<V> extends Runnable, Future<V> { void run(); }

    由于FutureTask实现了Runnable,因此它既可以通过Thread包装来直接执行,也可以提交给ExecuteService来执行。并且还可以直接通过get()函数获取执行结果,该函数会阻塞,直到结果返回。

    参考: 《java 并发编程实战》 https://blog.csdn.net/KingCat666/article/details/77651024 https://blog.csdn.net/bboyfeiyu/article/details/24851847

    最新回复(0)