RemoteMatlabClient.java 文件源码

@Override
public Future<MatlabResult> exec(MatlabRequest request)
        throws MatlabException, IOException {
    Preconditions.checkState(session != null && session.isOpen());
    try {
        SettableFuture<MatlabResult> future = SettableFuture.create();
        SettableFuture<MatlabResult> oldFuture
                = this.responses.putIfAbsent(request.getId(), future);

        if (oldFuture != null) {
            // we already executed that request...
            return oldFuture;
        }
        session.getBasicRemote().sendObject(request);
        return future;

    } catch (EncodeException ex) {
        throw new RuntimeException(ex);
    }
}