Page History
...
연결이되어 계산을 수행하고 그 결과를 어떠한 목적지 (Sink)로 정확한 실행 순서로 흘려 보내는것입니다.
스레드 모델을 모델을 직접 사용하여 구현시 이 구현체는 아주 복잡할것입니다어려울것입니다. 특히나 비동적으로 수행된 결과의
순서를 맞추는것은 더욱더 복잡한 일이 될것입니다.
Akka에서는 AkkaStream에서는 다음과 같은 방법으로 단순화할수가 있습니다.
| Code Block | ||||
|---|---|---|---|---|
| ||||
var actorSystem = ActorSystem.Create("ServiceB");
var materializer = actorSystem.Materializer();
var runnablegraph= Source.From(Enumerable.Range(1, 100))
.Select(x => x + 1)
.Async() //이 키워드로 비동기 처리영역을 구분합니다.
.Select(x => x * 2)
.To(Sink.ForEach<int>(x => Console.WriteLine(x.ToString())));
runnablegraph.Run(materializer); |
...