future

1열

1답변

스칼라 Akka의 HTTP - 사용 경로를 반환 할 미래 [A] JSON

Akka HTTP 버전으로 "akka-HTTP" "com.typesafe.akka"%% % "10.0.11" 스트림 버전 " com.typesafe.akka "%%"akka 스트림 "%"2.5.7 " 재생 JSON 버전 :"com.typesafe.play "%%"플레이 JSON을 "%"2.6.7 " 내가 가지고있는 crudService에서 다음과 같은 방법

0열

1답변

폐쇄는 scala.concurrent.Future에 대한 루프에서 두 번째로 다음과 같은 <code>Future</code>을 만드는 두 번째를 호출

나는 두 가지 방법이 문제가 발생하고있어, 처음 예상대로 작동하지 : public class WorkersCoordinator { private static Logger LOGGER = LoggerFactory.getLogger(WorkersCoordinator.class); private final Timeout timeou

3열

4답변

멀티 스레딩없이 Future를 사용하는 이유는 무엇입니까?

일부 코드를 상속 받았으며 원래 개발자가 남긴 사람이 없습니다. 이 코드는 주로 CompletableFuture을 사용하며 처음 사용하기 때문에 계속 머리를 감싸려고 노력하고 있습니다. 내가 이해할 때, (Completable)Future은 일반적으로 시간이 많이 걸리는 작업이 실행되는 동안 우리가 다른 일을 할 수있게 해주는 몇 가지 멀티 스레딩 메커니즘

0열

1답변

스칼라 미래 블록 변환?

나는 다음과 같은 테스트 코드가 : 그것은 다음과 같은 출력을 생성 import scala.concurrent.{Await, Future} import scala.concurrent.duration.Duration import scala.util.Success import scala.concurrent.ExecutionContext.Implicits

0열

1답변

동시 HTTP GET 요청을 보낼 선물

몇 가지 동시 HTTP GET 요청을 보내고 모든 응답이 만료 될 때까지 대기하는 함수를 작성한다고 가정합니다. 하나 이상의 응답이 상태가 200이 아니거나 제한 시간 내에 있지 않으면 내 함수가 실패를 반환해야합니다. 나는 이런 식으로이 기능 tryGets을 쓰고 있어요 :는 import java.net.URL import scala.concurren

0열

1답변

Future가 while 루프에서 호출 될 때마다 호출되지 않습니다.

큰 시스템 내에서 처리되는 파일의 진행을 모니터하고 지속시키는 유틸리티를 빌드 중입니다. 이 파일은 큰 "text"파일 인 .csv, .xls, .txt 등입니다.이 파일은 Kafka에서 스트리밍 데이터로, Avro에 쓰거나 SQL DB로 대량 배치로 작성할 수 있습니다. 나는 처리 된 행의 수를 기록하고 RESTful API 호출을 사용하여 DB에 진행을

0열

1답변

스칼라 플레이 프레임 워크 비동기 액션에서 선물 결합/연결

저는 플레이 프레임 워크를 사용하여 나머지 API를 작성하려는 스케이프 초보자입니다. 다음 3 가지 데이터 액세스 방법이 있습니다 getDataDict: (dsType:String, name:String) => Future[Option[DatasetDictionary]] getDatasetData: (DatasetDictionary) => Future[L

0열

1답변

테스트 환경에서 Play를 구성하는 방법

Play 2.6 및 스칼라에 앱이 있고 설정 파일에서 Action 또는 Action.async가되도록 Future를 반환하거나 Future를 반환하도록 모든 액션을 구성하려고합니다. 그래서 프로덕션 환경이나 테스트 환경에서 작동하도록 전체 앱을 구성 할 수있었습니다. 나는 그것을하는 방법을 전혀 모른다. Hpw를 공부하고 구현할 수 있습니까? 감사합니다.

1열

2답변

Scala Future의지도에 오버 헤드가 추가됩니까?

내가이 같은 기능을 가지고 가정 : 이제 import scala.concurrent._ def plus2Future(fut: Future[Int]) (implicit ec: ExecutionContext): Future[Int] = fut.map(_ + 2) 내가 만들 plus2Future를 사용하여 오전 Future 새로운 : imp

0열

1답변

는 Akka 다른 유형

내가 가지고있는 서로 다른 유형의 3 scala.concurrent.Future과 akka.dispatch.Futures.sequence 내부 통지를 받았습니다하기 위해 그들을 구성 할 필요가의 미래를 구성 선언 된 Iterable<Future<Object>>가 Iterable<Future<Object>> futureIterable = new ArrayLi