Page History
...
Dispatcher 설정기능을 제공함으로 , Ator별 다른 성능목표를 가지고 , 성능전략을 세울수가 있습니다.
Dispatcher
...
| Expandnoformat |
|---|
custom-dispatcher {
type = Dispatcher
throughput = 100
} |
.NET ThreadPool 을 통해 작동이되며 대부분의 경우 이것만으로 충분합니다.
TaskDispatcher
...
| Expandnoformat |
|---|
custom-task-dispatcher {
type = TaskDispatcher
throughput = 100
} |
TPL 인프라를 사용합니다. ThreadPool과 유사하지만 병렬처리 Thread를 사용해야하는
특수한 케이스일때 사용합니다.
PinnedDispatcher
...
| Expandnoformat |
|---|
custom-dedicated-dispatcher {
type = PinnedDispatcher
} |
하나의 단일 전용 스레드만 사용합니다.
ForkJoinDispatcher
...
| No Format |
|---|
my-dispatcher {
type = ForkJoinDispatcher
throughput = 100
throughput-deadline-time = 0ms
dedicated-thread-pool {
thread-count = 3
deadlock-timeout = 3s
threadtype = background
}
} |
나머지 Dispatcher는 최적화된 각자의 스레드풀이 있습니다.
ForJoinDispatcher의 경우 전용 스레드풀을 사용하며, 이 스 케줄러를 이용할시
나머지 시스템에서 일부 액터를 분리할수가 있습니다.
나머지 Dispatcher는 최적화된 각자의 스레드풀이 있습니다.
적용샘플
...
SynchronizedDispatcher
...
| No Format |
|---|
synchronized-dispatcher {
type = "SynchronizedDispatcher"
throughput = 10
}
private void Form1_Load(object sender, System.EventArgs e)
{
system.ActorOf(Props.Create<UIWorker>().WithDispatcher("synchronized-dispatcher"), "ui-worker");
}
|
SynchronizedDispatcher 는 Actor가 UI를 업데이트를 한다고하면UI를 업데이트할수있는 전용 Actor입니다.
적용샘플
...
| Code Block | ||||||||
|---|---|---|---|---|---|---|---|---|
| ||||||||
public class ReActor : ReceiveActor
{
private ILoggingAdapter log = Context.GetLogger();
public ReActor()
{
Receive<string>(message => {
if(message == "slow") //slow메시지를 받으면, 지연시킵니다.(테스트 지연코드)
{
Task.Delay(500).Wait();
}
string reply = string.Format("I'am {0} RE:{1}", Self.Path, message);
log.Info(reply);
Sender.Tell(reply);
});
}
} |
| Code Block | ||||||||
|---|---|---|---|---|---|---|---|---|
| ||||||||
var actor1 = actorSystem.ActorOf(Props.Create<ReActor>().WithDispatcher("my-dispatcher"), "my-actor1");
var actor2 = actorSystem.ActorOf(Props.Create<ReActor>().WithDispatcher("my-dispatcher"), "my-actor2");
var actor3 = actorSystem.ActorOf(Props.Create<ReActor>().WithDispatcher("my-dispatcher"), "my-actor3");
for (int i=0; i < 100; i++)
{
actor1.Tell("slow");
actor2.Tell("slow");
actor3.Tell("slow");
}
Console.WriteLine("completed - send all"); |
Akka의 로그는 기본적으로 고유 스레드 아이디를 표시해줍니다.
| Expand | ||
|---|---|---|
| ||
스레드 1개만 사용이 됩니다. |
| Expand | ||
|---|---|---|
| ||
스레드 3개를 번갈아가며 사용합니다. |
대부분 사용할일이 없지만, 어떠한 액터가 메시지를 받으면 블락킹이되고 오래걸리는경우 (일반적으로 외부 RestAPI)
이와같은 전력을 통해 스레드수분리가 가능합니다. ( 기본 메시지처리기에 부하를 분리)