Java回调以及如何获取线程的执行结果

软件模块之间存在调用的接口，从调用方式来看，有同步调用、回调、异步调用这三种方式：

同步调用是是一种阻塞式调用，调用方要等待被调用方执行完毕返回后才能获取调用的执行结果，是一种单向调用。

回调是一种双向调用，调用方在执行被调用方后，被调用方会调用被调用方的接口；

异步调用是一种类似消息或者事件的机制，接口在收到某个消息或发生某事件时，会主动通知客户方，通常使用回调来实现异步调用。

Java回调的必须要素： 

1雇主类必须有可以被观察者调用的方法A； 

2观察者必须持有可以调用A的对象的引用。

在实际工作中，我们通常将方法A以interface或者内部类的形式来实现，然后把包含有A的类的对象引用传递到观察者中。

Java中的线程的返回值是void，并且是一个异步执行流，所以我们没有直接的方法来获取线程执行后的结果，即不能直接知道线程何时结束，以及合适去获取线程执行任务后的结果。由于回调的存在，我们可以在线程中以回调的方式通知线程的调用者线程的结束时间，并可以将任务的结果通过回调回送到调用者中。

java使用单纯的wait/notify是无法唤醒指定线程的

一般的做法是修改一个特定标识，然后notifyAll，被唤醒的线程查看该标识是否指定自己处理，是就运行下去，不是就继续wait

还有一种做法是针对每一个线程做一个wait object，要唤醒哪一个就notify哪一个object就行了，但是能不能这样做去取决于你的业务需求

java中提供了Future<V>接口和实现了Future接口的FutureTask<V> 类来将线程执行之后的结果返回（通过get()方法）。

1Future<V>接口

Runnable接口执行任务是不返回任何值的，Runnable的run()方法的执行结果是void,而Future接口的call方法是有返回结果的，这是Runnable跟Future的区别之一，它们的另一个不同之处就是实现了Runnable接口的任务执行是调用ExecutorService的execute(Runnable task)方法，而实现了Future接口的任务是调用ExecutorService的submit(Future task)方法。调用Future的get()方法就能直接得到任务的返回值，该方法会一直阻塞直到任务的结果出来为止，我们可以调用Future的isDone()方法来判断该任务的结果是否准备就绪。

[java] view plain copy

import javautilconcurrentCallable;

import javautilconcurrentExecutionException;

import javautilconcurrentExecutorService;

import javautilconcurrentExecutors;

import javautilconcurrentFuture;

public class TestFuture {

public static void main(String[] args) throws InterruptedException, ExecutionException {

ExecutorService executor = ExecutorsnewCachedThreadPool();

Future result1 = executorsubmit(new Callable() {

@Override

public Integer call() throws Exception {

int sum = 0;

for (int i = 0; i < 10; i++) {

sum += i;

}

return sum;

}

});

Future result2 = executorsubmit(new Callable() {

@Override

public Integer call() throws Exception {

int sum = 0;

for (int i = 10; i < 100; i++) {

sum += i;

}

return sum;

}

});

executorshutdown();

Systemoutprintln(result1get() + result2get());

}

}

2FutureTask类

FutureTask实现了Future接口，将一个Callable实例作为参数传给它，就能创建一个FutureTask实例，然后用ExecutorService的submit方法来执行这个实例。最后同样是用get方法获取线程执行后的结果。

[plain] view plain copy

import javautilconcurrentCallable;

import javautilconcurrentExecutionException;

import javautilconcurrentExecutorService;

import javautilconcurrentExecutors;

import javautilconcurrentFutureTask;

public class TestFutureTask {

public static void main(String[] args) throws InterruptedException, ExecutionException {

ExecutorService executor = ExecutorsnewCachedThreadPool();

Callable task = new Callable() {

@Override

public String call() throws Exception {

return "结果";

}

};

FutureTask ft = new FutureTask(task);

executorsubmit(ft);

Systemoutprintln(ftget());

executorshutdown();

}

}empty

在进行服务器处理的过程中，需要保证数据的正确处理，那么最重要的就是使用不同的数据处理模式进行运算。在整个过程中，可能很多人对服务器的知识并不了解，那么应该如何进行Java开发服务器的线程处理呢，关于线程处理有哪些知识？下面昌平北大青鸟为大家介绍关键服务器线程处理的简单知识。

1、BIO线程模型

在JDK14中引入JavaNIO之前，所有基于Java的Socket通信都使用了同步阻塞模式（BIO）。这种请求-响应通信模型简化了上层的应用程序开发上，但在具有性能和可靠性的情况下，存在一个巨大的瓶颈。在一段时间里面，大型应用程序服务器主要是用C或C++开发的，因为它们可以直接使用 *** 作系统提供的异步I/O或AIO功能。

当流量增加且响应时间延迟增加时，JavaBIO开发的服务器软件只能通过硬件的不断扩展来满足并发性和低延迟的情况，这极大地增加了企业的成本和群集大小。系统的不断扩展，系统的可维护性也面临着巨大的挑战，只能通过购买性能更高的硬件服务器来解决问题，这将导致恶性循环的产生。

2、异步非阻塞线程模型

从JDK10到JDK13，Java的I/O类库非常原始。UNIX网络编程中的许多概念或接口未反映在I/O类库中，例如Pipe、Channel、Buffer和Selector等。在发布JDK14的时候，NIO正式发布JDK作为JSR-51。并且它还添加了一个javanio包，为异步I/O开发提供了许多API和库。

3、RPC性能三原则

影响RPC的性能主要有三大元素，其中主要为I/O模型、协议及线程。

I/O模型：使用什么样的通道传递给另一方，BIO，NIO或AIO发送数据，IO模型在很大程度上能够决定框架的性能。

协议：应该使用什么样的通信协议，Rest+JSON或基于TCP的专用二进制协议。参加电脑培训的过程中发现，协议的选择不同，性能模型也不同。内部专用二进制协议的性能通常可以比公共协议更好地设计。

线程：如何读取数据报？在执行读取后的编解码器的哪个线程中，如何分发编码消息，通信线程模型是不同的，并且对性能的影响也非常大。

以上就是关于Java回调以及如何获取线程的执行结果全部的内容，包括:Java回调以及如何获取线程的执行结果、java多线程怎么唤醒特定线程、如何在java中获取线程异步执行之后的结果等相关内容解答，如果想了解更多相关内容，可以关注我们，你们的支持是我们更新的动力！