Приложение зависит от результата других приложений, как мы можем достичь этого в Java? - PullRequest
Новая
       61

Приложение зависит от результата других приложений, как мы можем достичь этого в Java?

0 голосов
/ 27 февраля 2020

В интервью задается следующий вопрос. Пусть разные сервисы вызывают друг друга, есть одна услуга A, она вызывает сервис B, который занимает 20 секунд. Служба A также вызывает Служба C и Служба D , обе из которых занимают 25 секунд, 20 секунд соответственно. Когда служба A получает ответ от B, C, D, она должна вернуть ответ внешнему интерфейсу. Как вы этого добьетесь.

Я думаю, что интервьюер намеревался запросить многопоточность или ExecutorService из параллелизма. Поэтому я сказал, что мы можем использовать Future Object Return из интерфейса Callable. Для этого я написал следующий код: следующий код работает и возвращает результат: 45, что правильно.

Правильно ли мой подход, когда приложение зависит от результата другого приложения? В реальных приложениях мы используем этот подход? Пожалуйста, дайте мне знать, если есть какие-либо исправления в коде? 

import java.util.ArrayList;
import java.util.List;
import java.util.concurrent.*;

class Result{
    String applicationName;
    int result;
    public Result(String applicationName, int result){
        this.applicationName = applicationName;
        this.result = result;
    }
    public void add(int value){
        this.result += value;
    }

    public int getResult() {
        return result;
    }
}
class ApplicationA implements Callable<Result>{
    @Override
    public Result call() throws Exception {
        ExecutorService executorService = Executors.newFixedThreadPool(10);
        List<Future<Result>> list = new ArrayList<Future<Result>>();
        Future<Result> futureB = executorService.submit(new ApplicationB());
        list.add(futureB);
        Future<Result> futureC = executorService.submit(new ApplicationC());
        list.add(futureC);
        Future<Result> futureD = executorService.submit(new ApplicationD());
        list.add(futureD);

        Result result = new Result("ApplicationA", 12);
        for(Future<Result> future: list){
            try {
                Result result1 = future.get();
                result.add(result1.getResult());
            }catch (InterruptedException | ExecutionException e){
                e.printStackTrace();
            }
        }
        executorService.shutdown();
        return result;
    }
}
class ApplicationB implements Callable<Result>{
    @Override
    public Result call() throws Exception {
        Thread.sleep(20000);
        return new Result("ApplicationB",10);
    }
}
class ApplicationC implements Callable<Result>{
    @Override
    public Result call() throws Exception {
        Thread.sleep(25000);
        return new Result("ApplicationC",11);
    }
}
class ApplicationD implements Callable<Result>{
    @Override
    public Result call() throws Exception {
        Thread.sleep(20000);
        return new Result("ApplicationD",12);
    }
}
public class MultiApplicationDemo {
    public static void main(String[] args) throws ExecutionException, InterruptedException {
        ExecutorService executorService = Executors.newSingleThreadExecutor();
        Future<Result> futureA = executorService.submit(new ApplicationA());
        System.out.println(futureA.get().getResult());
        executorService.shutdown();
    }
}

1 Ответ

1 голос
/ 27 февраля 2020

Использование Future является операцией блокировки. CompletableFuture , с другой стороны, обеспечит вам неблокирующий механизм. Наряду с интерфейсом Future он также имеет интерфейс CompletionStage, который позволяет передавать несколько операций по конвейеру. 

CompletableFuture<String> completableFuture 
  = CompletableFuture.supplyAsync(() -> "Hello")
    .thenCompose(s -> CompletableFuture.supplyAsync(() -> s + " World"));

Он также позволяет корректно завершать работу в случае, если какой-либо из запрошенных сервисов генерирует исключения.

Это очень похоже на обещания в Javascript. enter image description here

...