Java多线程中Future设计模式怎么用

这篇文章将为大家详细讲解有关Java多线程中Future设计模式怎么用，小编觉得挺实用的，因此分享给大家做个参考，希望大家阅读完这篇文章后可以有所收获。

Future -> 代表的是未来的一个凭据

public interface Future {    T get() throws InterruptedException;}

AsynFuture -> Future具体实现类

public class AsynFuture implements Future {    private volatile boolean done = false;    private T result;    public void done(T result){        synchronized (this){            this.result = result;            this.done = true;            this.notifyAll();        }    }    /**     * 轮询 没有完成等待     */    @Override    public T get() throws InterruptedException {        synchronized (this) {            while (!done) {                this.wait();            }        }        return result;    }}

FutureService -> 桥接Future和FutureTask

public class FutureService {    /**     * 需进程等待     */    public  Future submit(final FutureTask task) {        AsynFuture asynFuture = new AsynFuture<>();        new Thread(() -> {            T result = task.call();            asynFuture.done(result);        }).start();        return asynFuture;    }    /**     * 运行完 自动回调     * 无需进程等待     */    public  Future submit(final FutureTask task, final Consumer consumer) {        AsynFuture asynFuture = new AsynFuture<>();        new Thread(() -> {            T result = task.call();            asynFuture.done(result);            consumer.accept(result);        }).start();        return asynFuture;    }}

FutureTask -> 将你的调用逻辑进行了隔离

public interface FutureTask {    T call();}

需要时回调：

/** * Future        -> 代表的是未来的一个凭据 * FutureTask    -> 将你的调用逻辑进行了隔离 * FutureService -> 桥接Future和FutureTask */public class SyncInvoker {    public static void main(String[] args) throws InterruptedException {        FutureService futureService = new FutureService();        Future future = futureService.submit(() -> {            try {                Thread.sleep(10001);            } catch (InterruptedException e) {                e.printStackTrace();            }            return "FINISH";        });        System.out.println("==============");        System.out.println("do other thing.");        Thread.sleep(1000);        System.out.println("==============");        /**         * 调用也形成了阻塞         */        System.out.println(future.get());    }}

运行：

==============
do other thing.
==============
FINISH

运行完自动回调:

//** * Future        -> 代表的是未来的一个凭据 * FutureTask    -> 将你的调用逻辑进行了隔离 * FutureService -> 桥接Future和FutureTask */public class SyncInvoker {    public static void main(String[] args) throws InterruptedException {        FutureService futureService = new FutureService();        futureService.submit(() -> {            try {                Thread.sleep(10001);            } catch (InterruptedException e) {                e.printStackTrace();            }            return "FINISH";        },System.out::println);        System.out.println("==============");        System.out.println("do other thing.");        Thread.sleep(1000);        System.out.println("==============");    }}

关于"Java多线程中Future设计模式怎么用"这篇文章就分享到这里了，希望以上内容可以对大家有一定的帮助，使各位可以学到更多知识，如果觉得文章不错，请把它分享出去让更多的人看到。