초기 요청을 받고, 일부 처리를 수행 한 다음 다른 서비스에 일부 요청/할일을 보내는 복잡한 백엔드 서비스에 actors을 어떻게 사용할 수 있습니까? 최종 결과를 계산할 때까지 일부 응답을 기다리고 응답을 기반으로 계속하는 방법을 결정하는 등의 작업을 수행 할 수 있습니다. 이러한 서비스를 구현하기 위해 액터를 사용하려고하면 다음과 같은 질문이 제기됩니다
Actor가 해당 메시지를 받으면 self에게 메시지를 보내는 Actor 풀에 메시지를 보내는 경우의 동작은 무엇입니까? 이 경우 self에게 메시지를 보내거나 메시지를 보낸 특정 액터 인스턴스로 메시지를 보내려고합니까? 이 시나리오의 의사 코드는 항상 가리키는 다음 ...
val system: ActorSystem = ActorSystem()
val
저는 Akka 라이브러리를 사용하고 있습니다. 여러 액터가 객체에서 함수를 호출하면 어떻게됩니까? 다른 액터가 객체에 액세스하는 것을 차단합니까? 내가 이것을 묻는 이유는 akka 배우와 함께 JBCrypt를 사용하기 때문입니다. 그리고 우리는 여러 문자열을 동시에 암호화 할 수 있기 때문에 JBcrypt.hash (...)를 호출하는 각 액터가 있습니다.
특정 시나리오에서 특정 테스트를 실행하기 위해 태그를 지정하고 싶습니다. (예를 들어, slow 만 빌드하는 동안 실행, 아직 반면 개발해야한다고.) 스칼라에서 을 ScalaTest의 FlatSpec를 사용하여 나는 taggedAs 및 scalatest의 Tag을 사용할 수 있습니다 알고 있습니다. 그러나 액터 테스트에서 같은 것을 달성하는 방법을 모르겠습
produce 코 루틴 빌더로 생성 된 생산자를 actor 루틴 빌더로 작성한 액터에 어떻게 연결할 수 있습니까? 기본적으로 producer의 전송 채널을 actor의 수신 채널로하고 싶습니다. 그렇게 할 수있는 간단한 방법이 있습니까? 제작자 나 배우가 사용할 채널을 명시 적으로 지정할 수있는 설명서에서 찾을 수없는 항목이 있습니다.
내 프로젝트에서 병렬 처리를 도입하고 내 응용 프로그램의 성능을 향상시키기 위해 Akka를 사용하기 시작했습니다. 이 점에 관해서는 GetSender() 메서드와 현재 액터의 부모 인 액터에게 다시 메시지를 보내야 할 때 getContext.parent() 메서드를 사용하는 것과 관련된 질문이 있습니다. 현재 처리되고있는 메세지 질문 내 프로그램의 컨텍스트
다음 코드를 확장하여 액터 요청 요청에 대해 알 수없는 액티비티로 작동하도록했습니다. implicit val timeout = Timeout(100 millis)
val sendRequestActor = context.actorOf(Props(new SendRequest(request)), "Send_Request_".concat(getActorNumbe
여기 내 코드입니다 : (예상대로)이 class Eapproximator
var step : F64
new create(step' :F64) =>
step = step'
fun evaluate() :F64 =>
var total = F64(0)
var value = F64(1)
while to
나는 디렉토리의 여러 그림이 화면에 표시되는 게임을하고있다. 나는 scene2d를 사용하고 있습니다. 하지만 어떤 이유로 이러한 사진이 화면에 표시되지 않습니다. 누구나 이유를 설명 할 수 있습니까? 사진은 아무것도를 그립니다 없다, 그래서 배우의 public class GameScreen extends Stage implements Screen {
특정 간격으로 배우에게 메시지를 보내야합니다. readLine() 바로 뒤에 넣어 :
val sendSchedule = system.scheduler.schedule(0 milliseconds, 5 minutes, senderActor, doSomething())
readLine()
object SendToActor extends App {