java異步接口如何實現

160次閱讀

共計 1842 個字符，預計需要花費 5 分鐘才能閱讀完成。

在 Java 中，可以使用回調、Future 和 CompletableFuture 等方式來實現異步接口。

回調：通過定義回調接口，在方法執行完畢后調用回調方法來處理結果。例如：

public interface AsyncCallback {void onSuccess(Object result);
    void onFailure(Exception e);
}

public interface AsyncService {void doSomethingAsync(AsyncCallback callback);
}

public class AsyncServiceImpl implements AsyncService {@Override
    public void doSomethingAsync(AsyncCallback callback) {// 異步操作 
        // 執行完畢后調用回調方法 
        if (success) {callback.onSuccess(result);
        } else {callback.onFailure(exception);
        }
    }
}

// 使用 
AsyncService asyncService = new AsyncServiceImpl();
asyncService.doSomethingAsync(new AsyncCallback() {@Override
    public void onSuccess(Object result) {// 處理成功結果 
    }

    @Override
    public void onFailure(Exception e) {// 處理異常情況 
    }
});

Future：通過 Future 對象來表示異步操作的結果，可以通過 get() 方法來獲取結果，也可以使用 isDone() 方法來判斷操作是否完成。例如：

public interface AsyncService {Future<Object> doSomethingAsync();
}

public class AsyncServiceImpl implements AsyncService {@Override
    public Future<Object> doSomethingAsync() {ExecutorService executor = Executors.newFixedThreadPool(1);
        return executor.submit(() -> {// 異步操作 
            return result;
        });
    }
}

// 使用 
AsyncService asyncService = new AsyncServiceImpl();
Future<Object> future = asyncService.doSomethingAsync();
while (!future.isDone()) {// 等待操作完成 
}
try {Object result = future.get();
    // 處理結果 
} catch (InterruptedException | ExecutionException e) {// 處理異常情況 
}

CompletableFuture：Java 8 引入的異步編程工具類，提供了豐富的方法來處理異步操作的結果。例如：

public interface AsyncService {CompletableFuture<Object> doSomethingAsync();
}

public class AsyncServiceImpl implements AsyncService {@Override
    public CompletableFuture<Object> doSomethingAsync() {CompletableFuture<Object> future = new CompletableFuture<>();
        // 異步操作 
        // 執行完畢后設置結果或異常 
        if (success) {future.complete(result);
        } else {future.completeExceptionally(exception);
        }
        return future;
    }
}

// 使用 
AsyncService asyncService = new AsyncServiceImpl();
asyncService.doSomethingAsync().thenAccept(result -> {// 處理成功結果 
}).exceptionally(e -> {// 處理異常情況 
    return null;
});