java - 用于关闭我的 SocketConversation 的 Lambda 表达式

Question

我有一个测试应用程序，它与服务器产生许多 SocketConversations。在过去，我会添加一个名为 ClosedWhenDone 的接口(interface)或定义关闭方法的接口(interface)，并在其中传递一个实例，以通知调用类 SocketConversation 已完成。

我是 java 8 的新手，想自学 lambda 函数。我看过这些:http://docs.oracle.com/javase/tutorial/java/javaOO/lambdaexpressions.html , http://viralpatel.net/blogs/lambda-expressions-java-tutorial/ , http://java.dzone.com/articles/why-we-need-lambda-expressions , http://java.dzone.com/articles/why-we-need-lambda-expressions-0 ，和http://java.dzone.com/articles/why-we-need-lambda-expressions .

因此，根据我的研究，我向构造函数添加了一个参数:

private Predicate<SocketConversation>       closePredicate;
private long                                delay;
private boolean                             done;
private int                                 index;

public SocketConversation(URI uri, int idx, String line, long delay, Predicate<SocketConversation> predicate) {
    index = idx;
    socket = new AirSocketClient(uri, this);
    closePredicate = predicate;
       ...
}

然后，当我的对话结束时，我会执行以下操作:

    socket.close();
    closePredicate.close(this);

但是，此处的关闭会生成错误:

The method close(SocketConversation) is undefined for the type Predicate<SocketConversation>

我错过了什么？

Answer 1

听起来您想要的是一个回调，通过调用调用者指定的一些代码，让调用者知道对话已完成。这听起来像是 lambda 的完美使用。在“旧”时代(Java 8 之前)，您需要指定一些接口(interface)，并且调用者将传入匿名内部类的实例。这可以使用 lambda 轻松完成。

您可以定义自己的接口(interface)，但在本例中不需要，因为大多数简单接口(interface)已经定义。在这种情况下，回调将传递一个 SocketConversation 的实例。并没有返回任何内容。其功能接口(interface)是 Consumer ，它已在 java.util.function 中定义。包裹。它是通用的，所以你需要一个 Consumer<SocketConversation> 。你的类看起来像这样:

private Consumer<SocketConversation> callback;

public SocketConversation(URI uri, int idx, String line, long delay, Consumer<SocketConversation> callback) {
    this.callback = callback;
    ...
}

稍后，当对话结束时，您可以执行以下操作:

    socket.close();
    callback.accept(this);

调用者可以传递 lambda 表达式作为回调，如下所示:

SocketConversation conv = new SocketConversation(uri, idx, line, delay,
    sc -> System.out.println("conversation " + sc + " is done"));