Class FutureCallback

src/main/java/com/aliyuncs/fc/core/FutureCallback.java:13–106

import java.util.concurrent.TimeoutException;

public class FutureCallback<Req, Res> extends AbstractWatchableCallback<Req, Res> implements Future<Res> {
    private boolean completed = false;
    private Res result;
    private Exception ex;

    public void onCompleted(Req request, Res result) {
        synchronized(this) {
            if (this.completed) {
                throw new IllegalStateException("completed() must not be invoked twice.");
            }

            this.completed = true;
            this.result = result;
            this.notifyAll();
        }

        Iterator it = this.callbacks.iterator();

        while(it.hasNext()) {
            FcCallback<Req, Res> callback = (FcCallback)it.next();
            callback.onCompleted(request, result);
        }

    }

    public void onFailed(Req request, Exception ex) {
        synchronized(this) {
            if (this.completed) {
                throw new IllegalStateException("completed() must not be invoked twice.");
            }

            this.completed = true;
            this.ex = ex;
            this.notifyAll();
        }

        Iterator it = this.callbacks.iterator();

        while(it.hasNext()) {
            FcCallback<Req, Res> callback = (FcCallback)it.next();
            callback.onFailed(request, ex);
        }

    }

    public boolean cancel(boolean mayInterruptIfRunning) {
        return false;
    }

    public boolean isCancelled() {
        return false;
    }

    public boolean isDone() {
        synchronized(this) {
            return this.completed;
        }
    }