当同一对象运行回调时重新创建对象的设计模式

Question

这是我正在尝试做的一个简单的玩具示例。

我有一个实现方法的 WebSocket 类onClose()。当 Socket 关闭时，它会触发事件处理程序（lambda 函数）。

public class WebSocket {

  ICallback cb;

  public WebSocket(ICallback cb) {

      this.cb = cb;

      this.onClose(); // Simulating socket closing

  }

  public void onClose() {

    this.cb.handle();

  }

  @FunctionalInterface

  public static interface ICallback {

    public abstract void handle();

  }

}

在父类中，我创建了此类的一个新实例。当套接字关闭时，我必须重新创建此类的新实例。（旧的不能用）

这是我的实现

class Parent {

  static WebSocket socket;

  public static void main(String[] args) {

    Parent.createSocket();

  }

  public static void createSocket() {

    Parent.socket = new WebSocket(() -> { Parent.createSocket(); });

  }

}

此代码有效

但是每当onClose()被触发时，一个新的帧就会被添加到堆栈中。

WebSocket在不增加堆栈大小的情况下重新创建对象的最佳模式是什么？

运行一个不断检查套接字状态的线程是否是一种可行的方法？IE：

while(socket.isOpen()) {

 Thread.sleep(1000);

}

createSocket();

Answer 1

堆栈溢出的原因是您的回调永远不会完成 - 您只需创建一个新套接字并运行它，但旧套接字保持活动状态。下一个也一样，依此类推。所以处理这个问题的一种方法是同时创建套接字，为方法提供onClose()一种实际终止的方法。您可以通过将实际创作提交给ExecutorService; 单线程的很好，因为毕竟，您只希望在给定时间运行一个套接字。class Parent {    static WebSocket socket;    // this is where the socket runs    private static final ExecutorService EXECUTOR = Executors.newSingleThreadExecutor();    public static void main(String[] args) {        createSocket();    }    private static void createSocket() {        Parent.socket = new WebSocket(() -> {            EXECUTOR.submit(Parent::createSocket);        });    }}这样，当回调被调用时onClose()，它会立即返回，并提交了新网络套接字的创建。该创建尚未发生，因为执行程序是单线程的，并且先前的套接字仍在该线程中运行。但是一旦完成，就会执行下一次提交——即刚刚提交的创建。作为旁注，同时运行网络连接几乎总是一个好主意，因此主线程仍然可用于其他任务。