Как написать асинхронные действия в игровой среде 2.5?

Question

Я написал следующий код, чтобы отправить электронное письмо как неблокирующее действие. Не работает более одного запроса.

CompletableFuture.supplyAsync(() -> 
EmailService.sendVerificationMail(appUser , mailString)). 
    thenApply(i -> ok("Got result: " + i)); 

В play.Promise является устаревшим в play.2.5 (Java). Мой предыдущий код не поддерживает. Поэтому, пожалуйста, дайте мне правильное решение, чтобы сделать мои действия неблокирующими.

Answer 1

Если функция EmailService.sendVerificationMail блокируется, то CompletableFuture делает ее неблокирующей на вызывающей нити. На самом деле он по-прежнему блокирует другую нить (возможно, общий ForkJoinPool).

Это не проблема, если работает только несколько задач электронной почты. Но если слишком много заданий электронной почты (скажем, 100 или более), они будут «доминировать» в пуле. Это приводит к «эффекту Convoy», а другим задачам приходится ждать гораздо больше времени для начала. Это может сильно повредить производительность сервера.

Если у вас есть много параллельных задач электронной почты, вы можете создать свой собственный пул, чтобы обрабатывать их, а не использовать общий пул. Пул потоков лучше, чем пул соединений fork, потому что он не позволяет краже работы.

Или вы можете найти асинхронные API EmailService или реализовать их самостоятельно, если это возможно.

Чтобы ответить на другой вопрос, теперь Play 2.5 использует CompletionStage для обещания по умолчанию. Он должен работать, если вы просто используете CompletionStage.

Некоторые примеры кода здесь. Обратите внимание на использование CompletionStage в возвращаемом типе.

public CompletionStage<Result> testAction() { 
    return CompletableFuture 
      .supplyAsync(() -> EmailService.sendVerificationMail(appUser, mailString), EmailService.getExecutor()) 
      .thenApply(i -> ok("Got result: " + i)); 
} 

Для получения более подробной информации, вы можете проверить Java Migration Guide на сайте Play.