GracefulChildActorTermination.cs | C# Online Compiler

GracefulChildActorTermination.cs by AaronPetabridge

using System;
using System.Collections.Generic;
using System.Linq;
using System.Threading.Tasks;
using Akka.Actor;
using Akka.Event;

public sealed class MyStopMessage{
	public static readonly MyStopMessage Instance = new MyStopMessage();
	private MyStopMessage(){}
}

public sealed class StartWork{
	public int WorkCount {get;}
	
	public StartWork(int workCount){
		WorkCount = workCount;
	}
}

public sealed class ActorA : ReceiveActor{
	private IActorRef _actorB;	
	
	private readonly ILoggingAdapter _log = Context.GetLogger();
	
	public ActorA(){
		Receive<StartWork>(w => {
			foreach(var i in Enumerable.Range(0, w.WorkCount)){
				_actorB.Tell(i);
			}
		});
		
		ReceiveAsync<MyStopMessage>(async _ => {
			_log.Info("Begin shutdown");
			
			// stop child actor B with the same custom message
			await _actorB.GracefulStop(TimeSpan.FromSeconds(10), _);
			
			// shut ourselves down after child is done
			Context.Stop(Self);
		});
	}
	
	protected override void PreStart(){
		_actorB = Context.ActorOf(Props.Create(() => new ActorB()), "b");
	}
}

public sealed class ActorB : ReceiveActor{
	private IActorRef _actorC;
	private IActorRef _actorD;
	
	private readonly ILoggingAdapter _log = Context.GetLogger();
	
	public ActorB(){
		Receive<int>(i => {
			_actorC.Tell(i);
			_actorD.Tell(i);
		});
		
		ReceiveAsync<MyStopMessage>(async _ => {
			
			_log.Info("Begin shutdown");
			
			// stop both actors in parallel
			var stopC = _actorC.GracefulStop(TimeSpan.FromSeconds(10));
			var stopD = _actorD.GracefulStop(TimeSpan.FromSeconds(10));
			
			// compose stop Tasks
			var bothStopped = Task.WhenAll(stopC, stopD);
			await bothStopped;
			
			// shut ourselves down immediately
			Context.Stop(Self);
		});
	}
	
	protected override void PreStart(){
		var workerProps = Props.Create(() => new WorkerActor());
		_actorC = Context.ActorOf(workerProps, "c");
		_actorD = Context.ActorOf(workerProps, "d");
	}
}

public sealed class WorkerActor : ReceiveActor {
	private readonly ILoggingAdapter _log = Context.GetLogger();
	
	public WorkerActor(){
		ReceiveAsync<int>(async i => {
			await Task.Delay(10);
			_log.Info("Received {0}", i);
		});
	}
}

public class Program
{
	public static async Task Main()
	{
		var actorSystem = ActorSystem.Create("test");
		
		var actorA = actorSystem.ActorOf(Props.Create(() => new ActorA()), "a");
		actorA.Tell(new StartWork(100));
		
		// equivalent to Tell + Context.Watch + Receive<Terminated>
		await actorA.GracefulStop(TimeSpan.FromSeconds(12), MyStopMessage.Instance);
	}
}

​x
 
using System;
using System.Collections.Generic;
using System.Linq;
using System.Threading.Tasks;
using Akka.Actor;
using Akka.Event;
​
public sealed class MyStopMessage{
    public static readonly MyStopMessage Instance = new MyStopMessage();
    private MyStopMessage(){}
}
​
public sealed class StartWork{
    public int WorkCount {get;}
    
    public StartWork(int workCount){
        WorkCount = workCount;
    }
}
​
public sealed class ActorA : ReceiveActor{
    private IActorRef _actorB;  
    
    private readonly ILoggingAdapter _log = Context.GetLogger();
    
    public ActorA(){
        Receive<StartWork>(w => {
            foreach(var i in Enumerable.Range(0, w.WorkCount)){
                _actorB.Tell(i);
            }
        });
        
        ReceiveAsync<MyStopMessage>(async _ => {
            _log.Info("Begin shutdown");
            
            // stop child actor B with the same custom message
            await _actorB.GracefulStop(TimeSpan.FromSeconds(10), _);
            
            // shut ourselves down after child is done
            Context.Stop(Self);
        });
    }
    
    protected override void PreStart(){
        _actorB = Context.ActorOf(Props.Create(() => new ActorB()), "b");
    }
}
​
public sealed class ActorB : ReceiveActor{
    private IActorRef _actorC;
    private IActorRef _actorD;
    
    private readonly ILoggingAdapter _log = Context.GetLogger();
    
    public ActorB(){
        Receive<int>(i => {
            _actorC.Tell(i);
            _actorD.Tell(i);
        });
        
        ReceiveAsync<MyStopMessage>(async _ => {
            
            _log.Info("Begin shutdown");
            
            // stop both actors in parallel
            var stopC = _actorC.GracefulStop(TimeSpan.FromSeconds(10));
            var stopD = _actorD.GracefulStop(TimeSpan.FromSeconds(10));
            
            // compose stop Tasks
            var bothStopped = Task.WhenAll(stopC, stopD);
            await bothStopped;
            
            // shut ourselves down immediately
            Context.Stop(Self);
        });
    }
    
    protected override void PreStart(){
        var workerProps = Props.Create(() => new WorkerActor());
        _actorC = Context.ActorOf(workerProps, "c");
        _actorD = Context.ActorOf(workerProps, "d");
    }
}
​
public sealed class WorkerActor : ReceiveActor {
    private readonly ILoggingAdapter _log = Context.GetLogger();
    
    public WorkerActor(){
        ReceiveAsync<int>(async i => {
            await Task.Delay(10);
            _log.Info("Received {0}", i);
        });
    }
}
​
public class Program
{
    public static async Task Main()
    {
        var actorSystem = ActorSystem.Create("test");
        
        var actorA = actorSystem.ActorOf(Props.Create(() => new ActorA()), "a");
        actorA.Tell(new StartWork(100));
        
        // equivalent to Tell + Context.Watch + Receive<Terminated>
        await actorA.GracefulStop(TimeSpan.FromSeconds(12), MyStopMessage.Instance);
    }
}

[39;49m[INFO][06/07/2025 15:49:12][Thread 0011][akka://test/user/a] Begin shutdown
[39;49m[39;49m[INFO][06/07/2025 15:49:12][Thread 0011][akka://test/user/a/b] Begin shutdown
[39;49m[39;49m[INFO][06/07/2025 15:49:12][Thread 0012][akka://test/user/a/b/d] Received 0
[39;49m[39;49m[INFO][06/07/2025 15:49:12][Thread 0013][akka://test/user/a/b/c] Received 0
[39;49m[39;49m[INFO][06/07/2025 15:49:12][Thread 0013][akka://test/user/a/b/d] Received 1
[39;49m[39;49m[INFO][06/07/2025 15:49:12][Thread 0008][akka://test/user/a/b/c] Received 1
[39;49m[39;49m[INFO][06/07/2025 15:49:12][Thread 0012][akka://test/user/a/b/d] Received 2
[39;49m[39;49m[INFO][06/07/2025 15:49:12][Thread 0013][akka://test/user/a/b/c] Received 2
[39;49m[39;49m[INFO][06/07/2025 15:49:12][Thread 0013][akka://test/user/a/b/c] Received 3
[39;49m[39;49m[INFO][06/07/2025 15:49:12][Thread 0008][akka://test/user/a/b/d] Received 3
[39;49m[39;49m[INFO][06/07/2025 15:49:12][Thread 0012][akka://test/user/a/b/c] Received 4
[39;49m[39;49m[INFO][06/07/2025 15:49:12][Thread 0013][akka://test/user/a/b/d] Received 4
[39;49m[39;49m[INFO][06/07/2025 15:49:12][Thread 0008][akka://test/user/a/b/d] Received 5
[39;49m[39;49m[INFO][06/07/2025 15:49:12][Thread 0013][akka://test/user/a/b/c] Received 5
[39;49m[39;49m[INFO][06/07/2025 15:49:12][Thread 0012][akka://test/user/a/b/c] Received 6
[39;49m[39;49m[INFO][06/07/2025 15:49:12][Thread 0013][akka://test/user/a/b/d] Received 6
[39;49m[39;49m[INFO][06/07/2025 15:49:12][Thread 0012][akka://test/user/a/b/d] Received 7
[39;49m[39;49m[INFO][06/07/2025 15:49:12][Thread 0008][akka://test/user/a/b/c] Received 7
[39;49m[39;49m[INFO][06/07/2025 15:49:12][Thread 0013][akka://test/user/a/b/d] Received 8
[39;49m[39;49m[INFO][06/07/2025 15:49:12][Thread 0013][akka://test/user/a/b/c] Received 8
[39;49m[39;49m[INFO][06/07/2025 15:49:12][Thread 0012][akka://test/user/a/b/c] Received 9
[39;49m[39;49m[INFO][06/07/2025 15:49:12][Thread 0012][akka://test/user/a/b/d] Received 9
[39;49m[39;49m[INFO][06/07/2025 15:49:12][Thread 0008][akka://test/user/a/b/d] Received 10
[39;49m[39;49m[INFO][06/07/2025 15:49:12][Thread 0012][akka://test/user/a/b/c] Received 10
[39;49m[39;49m[INFO][06/07/2025 15:49:12][Thread 0013][akka://test/user/a/b/d] Received 11
[39;49m[39;49m[INFO][06/07/2025 15:49:12][Thread 0012][akka://test/user/a/b/c] Received 11
[39;49m[39;49m[INFO][06/07/2025 15:49:12][Thread 0012][akka://test/user/a/b/c] Received 12
[39;49m[39;49m[INFO][06/07/2025 15:49:12][Thread 0008][akka://test/user/a/b/d] Received 12
[39;49m[39;49m[INFO][06/07/2025 15:49:12][Thread 0013][akka://test/user/a/b/d] Received 13
[39;49m[39;49m[INFO][06/07/2025 15:49:12][Thread 0012][akka://test/user/a/b/c] Received 13
[39;49m[39;49m[INFO][06/07/2025 15:49:12][Thread 0008][akka://test/user/a/b/c] Received 14
[39;49m[39;49m[INFO][06/07/2025 15:49:12][Thread 0013][akka://test/user/a/b/d] Received 14
[39;49m[39;49m[INFO][06/07/2025 15:49:12][Thread 0013][akka://test/user/a/b/d] Received 15
[39;49m[39;49m[INFO][06/07/2025 15:49:12][Thread 0012][akka://test/user/a/b/c] Received 15
[39;49m[39;49m[INFO][06/07/2025 15:49:12][Thread 0013][akka://test/user/a/b/d] Received 16
[39;49m[39;49m[INFO][06/07/2025 15:49:12][Thread 0008][akka://test/user/a/b/c] Received 16
[39;49m[39;49m[INFO][06/07/2025 15:49:12][Thread 0012][akka://test/user/a/b/d] Received 17
[39;49m[39;49m[INFO][06/07/2025 15:49:12][Thread 0013][akka://test/user/a/b/c] Received 17
[39;49m[39;49m[INFO][06/07/2025 15:49:12][Thread 0012][akka://test/user/a/b/c] Received 18
[39;49m[39;49m[INFO][06/07/2025 15:49:12][Thread 0008][akka://test/user/a/b/d] Received 18
[39;49m[39;49m[INFO][06/07/2025 15:49:12][Thread 0013][akka://test/user/a/b/d] Received 19
[39;49m[39;49m[INFO][06/07/2025 15:49:12][Thread 0012][akka://test/user/a/b/c] Received 19
[39;49m[39;49m[INFO][06/07/2025 15:49:12][Thread 0012][akka://test/user/a/b/c] Received 20
[39;49m[39;49m[INFO][06/07/2025 15:49:12][Thread 0008][akka://test/user/a/b/d] Received 20
[39;49m[39;49m[INFO][06/07/2025 15:49:12][Thread 0008][akka://test/user/a/b/c] Received 21
[39;49m[39;49m[INFO][06/07/2025 15:49:12][Thread 0008][akka://test/user/a/b/d] Received 21
[39;49m[39;49m[INFO][06/07/2025 15:49:12][Thread 0008][akka://test/user/a/b/d] Received 22
[39;49m[39;49m[INFO][06/07/2025 15:49:12][Thread 0012][akka://test/user/a/b/c] Received 22
[39;49m[39;49m[INFO][06/07/2025 15:49:12][Thread 0012][akka://test/user/a/b/c] Received 23
[39;49m[39;49m[INFO][06/07/2025 15:49:12][Thread 0013][akka://test/user/a/b/d] Received 23
[39;49m[39;49m[INFO][06/07/2025 15:49:12][Thread 0008][akka://test/user/a/b/c] Received 24
[39;49m[39;49m[INFO][06/07/2025 15:49:12][Thread 0013][akka://test/user/a/b/d] Received 24
[39;49m[39;49m[INFO][06/07/2025 15:49:12][Thread 0013][akka://test/user/a/b/c] Received 25
[39;49m[39;49m[INFO][06/07/2025 15:49:12][Thread 0012][akka://test/user/a/b/d] Received 25
[39;49m[39;49m[INFO][06/07/2025 15:49:12][Thread 0008][akka://test/user/a/b/c] Received 26
[39;49m[39;49m[INFO][06/07/2025 15:49:12][Thread 0013][akka://test/user/a/b/d] Received 26
[39;49m[39;49m[INFO][06/07/2025 15:49:12][Thread 0008][akka://test/user/a/b/c] Received 27
[39;49m[39;49m[INFO][06/07/2025 15:49:12][Thread 0012][akka://test/user/a/b/d] Received 27
[39;49m[39;49m[INFO][06/07/2025 15:49:12][Thread 0013][akka://test/user/a/b/d] Received 28
[39;49m[39;49m[INFO][06/07/2025 15:49:12][Thread 0008][akka://test/user/a/b/c] Received 28
[39;49m[39;49m[INFO][06/07/2025 15:49:12][Thread 0008][akka://test/user/a/b/d] Received 29
[39;49m[39;49m[INFO][06/07/2025 15:49:12][Thread 0013][akka://test/user/a/b/c] Received 29
[39;49m[39;49m[INFO][06/07/2025 15:49:12][Thread 0012][akka://test/user/a/b/c] Received 30
[39;49m[39;49m[INFO][06/07/2025 15:49:12][Thread 0008][akka://test/user/a/b/d] Received 30
[39;49m[39;49m[INFO][06/07/2025 15:49:12][Thread 0013][akka://test/user/a/b/d] Received 31
[39;49m[39;49m[INFO][06/07/2025 15:49:12][Thread 0013][akka://test/user/a/b/c] Received 31
[39;49m[39;49m[INFO][06/07/2025 15:49:12][Thread 0012][akka://test/user/a/b/c] Received 32
[39;49m[39;49m[INFO][06/07/2025 15:49:12][Thread 0013][akka://test/user/a/b/d] Received 32
[39;49m[39;49m[INFO][06/07/2025 15:49:12][Thread 0008][akka://test/user/a/b/d] Received 33
[39;49m[39;49m[INFO][06/07/2025 15:49:12][Thread 0012][akka://test/user/a/b/c] Received 33
[39;49m[39;49m[INFO][06/07/2025 15:49:12][Thread 0013][akka://test/user/a/b/d] Received 34
[39;49m[39;49m[INFO][06/07/2025 15:49:12][Thread 0012][akka://test/user/a/b/c] Received 34
[39;49m[39;49m[INFO][06/07/2025 15:49:12][Thread 0008][akka://test/user/a/b/c] Received 35
[39;49m[39;49m[INFO][06/07/2025 15:49:12][Thread 0013][akka://test/user/a/b/d] Received 35
[39;49m[39;49m[INFO][06/07/2025 15:49:12][Thread 0008][akka://test/user/a/b/c] Received 36
[39;49m[39;49m[INFO][06/07/2025 15:49:12][Thread 0013][akka://test/user/a/b/d] Received 36
[39;49m[39;49m[INFO][06/07/2025 15:49:12][Thread 0012][akka://test/user/a/b/d] Received 37
[39;49m[39;49m[INFO][06/07/2025 15:49:12][Thread 0013][akka://test/user/a/b/c] Received 37
[39;49m[39;49m[INFO][06/07/2025 15:49:12][Thread 0008][akka://test/user/a/b/d] Received 38
[39;49m[39;49m[INFO][06/07/2025 15:49:12][Thread 0013][akka://test/user/a/b/c] Received 38
[39;49m[39;49m[INFO][06/07/2025 15:49:12][Thread 0012][akka://test/user/a/b/d] Received 39
[39;49m[39;49m[INFO][06/07/2025 15:49:12][Thread 0013][akka://test/user/a/b/c] Received 39
[39;49m[39;49m[INFO][06/07/2025 15:49:12][Thread 0008][akka://test/user/a/b/d] Received 40
[39;49m[39;49m[INFO][06/07/2025 15:49:12][Thread 0013][akka://test/user/a/b/c] Received 40
[39;49m[39;49m[INFO][06/07/2025 15:49:12][Thread 0013][akka://test/user/a/b/c] Received 41
[39;49m[39;49m[INFO][06/07/2025 15:49:12][Thread 0012][akka://test/user/a/b/d] Received 41
[39;49m[39;49m[INFO][06/07/2025 15:49:12][Thread 0008][akka://test/user/a/b/c] Received 42
[39;49m[39;49m[INFO][06/07/2025 15:49:12][Thread 0013][akka://test/user/a/b/d] Received 42
[39;49m[39;49m[INFO][06/07/2025 15:49:12][Thread 0012][akka://test/user/a/b/d] Received 43
[39;49m[39;49m[INFO][06/07/2025 15:49:12][Thread 0013][akka://test/user/a/b/c] Received 43
[39;49m[39;49m[INFO][06/07/2025 15:49:12][Thread 0012][akka://test/user/a/b/c] Received 44
[39;49m[39;49m[INFO][06/07/2025 15:49:12][Thread 0008][akka://test/user/a/b/d] Received 44
[39;49m[39;49m[INFO][06/07/2025 15:49:12][Thread 0012][akka://test/user/a/b/d] Received 45
[39;49m[39;49m[INFO][06/07/2025 15:49:12][Thread 0008][akka://test/user/a/b/c] Received 45
[39;49m[39;49m[INFO][06/07/2025 15:49:12][Thread 0012][akka://test/user/a/b/c] Received 46
[39;49m[39;49m[INFO][06/07/2025 15:49:12][Thread 0013][akka://test/user/a/b/d] Received 46
[39;49m[39;49m[INFO][06/07/2025 15:49:12][Thread 0008][akka://test/user/a/b/d] Received 47
[39;49m[39;49m[INFO][06/07/2025 15:49:12][Thread 0013][akka://test/user/a/b/c] Received 47
[39;49m[39;49m[INFO][06/07/2025 15:49:12][Thread 0012][akka://test/user/a/b/d] Received 48
[39;49m[39;49m[INFO][06/07/2025 15:49:12][Thread 0008][akka://test/user/a/b/c] Received 48
[39;49m[39;49m[INFO][06/07/2025 15:49:12][Thread 0013][akka://test/user/a/b/c] Received 49
[39;49m[39;49m[INFO][06/07/2025 15:49:12][Thread 0008][akka://test/user/a/b/d] Received 49
[39;49m[39;49m[INFO][06/07/2025 15:49:12][Thread 0013][akka://test/user/a/b/c] Received 50
[39;49m[39;49m[INFO][06/07/2025 15:49:12][Thread 0012][akka://test/user/a/b/d] Received 50
[39;49m[39;49m[INFO][06/07/2025 15:49:12][Thread 0013][akka://test/user/a/b/c] Received 51
[39;49m[39;49m[INFO][06/07/2025 15:49:12][Thread 0008][akka://test/user/a/b/d] Received 51
[39;49m[39;49m[INFO][06/07/2025 15:49:12][Thread 0008][akka://test/user/a/b/c] Received 52
[39;49m[39;49m[INFO][06/07/2025 15:49:12][Thread 0013][akka://test/user/a/b/d] Received 52
[39;49m[39;49m[INFO][06/07/2025 15:49:12][Thread 0013][akka://test/user/a/b/d] Received 53
[39;49m[39;49m[INFO][06/07/2025 15:49:12][Thread 0012][akka://test/user/a/b/c] Received 53
[39;49m[39;49m[INFO][06/07/2025 15:49:12][Thread 0013][akka://test/user/a/b/d] Received 54
[39;49m[39;49m[INFO][06/07/2025 15:49:12][Thread 0008][akka://test/user/a/b/c] Received 54
[39;49m[39;49m[INFO][06/07/2025 15:49:12][Thread 0008][akka://test/user/a/b/d] Received 55
[39;49m[39;49m[INFO][06/07/2025 15:49:12][Thread 0013][akka://test/user/a/b/c] Received 55
[39;49m[39;49m[INFO][06/07/2025 15:49:12][Thread 0012][akka://test/user/a/b/d] Received 56
[39;49m[39;49m[INFO][06/07/2025 15:49:12][Thread 0008][akka://test/user/a/b/c] Received 56
[39;49m[39;49m[INFO][06/07/2025 15:49:12][Thread 0013][akka://test/user/a/b/d] Received 57
[39;49m[39;49m[INFO][06/07/2025 15:49:12][Thread 0012][akka://test/user/a/b/c] Received 57
[39;49m[39;49m[INFO][06/07/2025 15:49:12][Thread 0008][akka://test/user/a/b/c] Received 58
[39;49m[39;49m[INFO][06/07/2025 15:49:12][Thread 0012][akka://test/user/a/b/d] Received 58
[39;49m[39;49m[INFO][06/07/2025 15:49:12][Thread 0012][akka://test/user/a/b/d] Received 59
[39;49m[39;49m[INFO][06/07/2025 15:49:12][Thread 0013][akka://test/user/a/b/c] Received 59
[39;49m[39;49m[INFO][06/07/2025 15:49:12][Thread 0008][akka://test/user/a/b/d] Received 60
[39;49m[39;49m[INFO][06/07/2025 15:49:12][Thread 0011][akka://test/user/a/b/c] Received 60
[39;49m[39;49m[INFO][06/07/2025 15:49:12][Thread 0011][akka://test/user/a/b/c] Received 61
[39;49m[39;49m[INFO][06/07/2025 15:49:12][Thread 0008][akka://test/user/a/b/d] Received 61
[39;49m[39;49m[INFO][06/07/2025 15:49:12][Thread 0008][akka://test/user/a/b/d] Received 62
[39;49m[39;49m[INFO][06/07/2025 15:49:12][Thread 0011][akka://test/user/a/b/c] Received 62
[39;49m[39;49m[INFO][06/07/2025 15:49:13][Thread 0011][akka://test/user/a/b/d] Received 63
[39;49m[39;49m[INFO][06/07/2025 15:49:13][Thread 0008][akka://test/user/a/b/c] Received 63
[39;49m[39;49m[INFO][06/07/2025 15:49:13][Thread 0008][akka://test/user/a/b/c] Received 64
[39;49m[39;49m[INFO][06/07/2025 15:49:13][Thread 0011][akka://test/user/a/b/d] Received 64
[39;49m[39;49m[INFO][06/07/2025 15:49:13][Thread 0008][akka://test/user/a/b/c] Received 65
[39;49m[39;49m[INFO][06/07/2025 15:49:13][Thread 0011][akka://test/user/a/b/d] Received 65
[39;49m[39;49m[INFO][06/07/2025 15:49:13][Thread 0011][akka://test/user/a/b/c] Received 66
[39;49m[39;49m[INFO][06/07/2025 15:49:13][Thread 0013][akka://test/user/a/b/d] Received 66
[39;49m[39;49m[INFO][06/07/2025 15:49:13][Thread 0008][akka://test/user/a/b/c] Received 67
[39;49m[39;49m[INFO][06/07/2025 15:49:13][Thread 0013][akka://test/user/a/b/d] Received 67
[39;49m[39;49m[INFO][06/07/2025 15:49:13][Thread 0011][akka://test/user/a/b/d] Received 68
[39;49m[39;49m[INFO][06/07/2025 15:49:13][Thread 0013][akka://test/user/a/b/c] Received 68
[39;49m[39;49m[INFO][06/07/2025 15:49:13][Thread 0011][akka://test/user/a/b/c] Received 69
[39;49m[39;49m[INFO][06/07/2025 15:49:13][Thread 0013][akka://test/user/a/b/d] Received 69
[39;49m[39;49m[INFO][06/07/2025 15:49:13][Thread 0008][akka://test/user/a/b/d] Received 70
[39;49m[39;49m[INFO][06/07/2025 15:49:13][Thread 0013][akka://test/user/a/b/c] Received 70
[39;49m[39;49m[INFO][06/07/2025 15:49:13][Thread 0011][akka://test/user/a/b/d] Received 71
[39;49m[39;49m[INFO][06/07/2025 15:49:13][Thread 0008][akka://test/user/a/b/c] Received 71
[39;49m[39;49m[INFO][06/07/2025 15:49:13][Thread 0011][akka://test/user/a/b/d] Received 72
[39;49m[39;49m[INFO][06/07/2025 15:49:13][Thread 0008][akka://test/user/a/b/c] Received 72
[39;49m[39;49m[INFO][06/07/2025 15:49:13][Thread 0008][akka://test/user/a/b/c] Received 73
[39;49m[39;49m[INFO][06/07/2025 15:49:13][Thread 0013][akka://test/user/a/b/d] Received 73
[39;49m[39;49m[INFO][06/07/2025 15:49:13][Thread 0008][akka://test/user/a/b/d] Received 74
[39;49m[39;49m[INFO][06/07/2025 15:49:13][Thread 0013][akka://test/user/a/b/c] Received 74
[39;49m[39;49m[INFO][06/07/2025 15:49:13][Thread 0011][akka://test/user/a/b/c] Received 75
[39;49m[39;49m[INFO][06/07/2025 15:49:13][Thread 0008][akka://test/user/a/b/d] Received 75
[39;49m[39;49m[INFO][06/07/2025 15:49:13][Thread 0008][akka://test/user/a/b/d] Received 76
[39;49m[39;49m[INFO][06/07/2025 15:49:13][Thread 0011][akka://test/user/a/b/c] Received 76
[39;49m[39;49m[INFO][06/07/2025 15:49:13][Thread 0011][akka://test/user/a/b/c] Received 77
[39;49m[39;49m[INFO][06/07/2025 15:49:13][Thread 0011][akka://test/user/a/b/d] Received 77
[39;49m[39;49m[INFO][06/07/2025 15:49:13][Thread 0008][akka://test/user/a/b/d] Received 78
[39;49m[39;49m[INFO][06/07/2025 15:49:13][Thread 0013][akka://test/user/a/b/c] Received 78
[39;49m[39;49m[INFO][06/07/2025 15:49:13][Thread 0013][akka://test/user/a/b/d] Received 79
[39;49m[39;49m[INFO][06/07/2025 15:49:13][Thread 0011][akka://test/user/a/b/c] Received 79
[39;49m[39;49m[INFO][06/07/2025 15:49:13][Thread 0013][akka://test/user/a/b/d] Received 80
[39;49m[39;49m[INFO][06/07/2025 15:49:13][Thread 0011][akka://test/user/a/b/c] Received 80
[39;49m[39;49m[INFO][06/07/2025 15:49:13][Thread 0011][akka://test/user/a/b/c] Received 81
[39;49m[39;49m[INFO][06/07/2025 15:49:13][Thread 0013][akka://test/user/a/b/d] Received 81
[39;49m[39;49m[INFO][06/07/2025 15:49:13][Thread 0011][akka://test/user/a/b/c] Received 82
[39;49m[39;49m[INFO][06/07/2025 15:49:13][Thread 0013][akka://test/user/a/b/d] Received 82
[39;49m[39;49m[INFO][06/07/2025 15:49:13][Thread 0013][akka://test/user/a/b/c] Received 83
[39;49m[39;49m[INFO][06/07/2025 15:49:13][Thread 0011][akka://test/user/a/b/d] Received 83
[39;49m[39;49m[INFO][06/07/2025 15:49:13][Thread 0013][akka://test/user/a/b/c] Received 84
[39;49m[39;49m[INFO][06/07/2025 15:49:13][Thread 0013][akka://test/user/a/b/d] Received 84
[39;49m[39;49m[INFO][06/07/2025 15:49:13][Thread 0011][akka://test/user/a/b/c] Received 85
[39;49m[39;49m[INFO][06/07/2025 15:49:13][Thread 0008][akka://test/user/a/b/d] Received 85
[39;49m[39;49m[INFO][06/07/2025 15:49:13][Thread 0013][akka://test/user/a/b/d] Received 86
[39;49m[39;49m[INFO][06/07/2025 15:49:13][Thread 0008][akka://test/user/a/b/c] Received 86
[39;49m[39;49m[INFO][06/07/2025 15:49:13][Thread 0008][akka://test/user/a/b/c] Received 87
[39;49m[39;49m[INFO][06/07/2025 15:49:13][Thread 0013][akka://test/user/a/b/d] Received 87
[39;49m[39;49m[INFO][06/07/2025 15:49:13][Thread 0008][akka://test/user/a/b/d] Received 88
[39;49m[39;49m[INFO][06/07/2025 15:49:13][Thread 0013][akka://test/user/a/b/c] Received 88
[39;49m[39;49m[INFO][06/07/2025 15:49:13][Thread 0011][akka://test/user/a/b/c] Received 89
[39;49m[39;49m[INFO][06/07/2025 15:49:13][Thread 0013][akka://test/user/a/b/d] Received 89
[39;49m[39;49m[INFO][06/07/2025 15:49:13][Thread 0011][akka://test/user/a/b/d] Received 90
[39;49m[39;49m[INFO][06/07/2025 15:49:13][Thread 0011][akka://test/user/a/b/c] Received 90
[39;49m[39;49m[INFO][06/07/2025 15:49:13][Thread 0011][akka://test/user/a/b/c] Received 91
[39;49m[39;49m[INFO][06/07/2025 15:49:13][Thread 0011][akka://test/user/a/b/d] Received 91
[39;49m[39;49m[INFO][06/07/2025 15:49:13][Thread 0011][akka://test/user/a/b/c] Received 92
[39;49m[39;49m[INFO][06/07/2025 15:49:13][Thread 0011][akka://test/user/a/b/d] Received 92
[39;49m[39;49m[INFO][06/07/2025 15:49:13][Thread 0011][akka://test/user/a/b/d] Received 93
[39;49m[39;49m[INFO][06/07/2025 15:49:13][Thread 0011][akka://test/user/a/b/c] Received 93
[39;49m[39;49m[INFO][06/07/2025 15:49:13][Thread 0008][akka://test/user/a/b/c] Received 94
[39;49m[39;49m[INFO][06/07/2025 15:49:13][Thread 0008][akka://test/user/a/b/d] Received 94
[39;49m[39;49m[INFO][06/07/2025 15:49:13][Thread 0011][akka://test/user/a/b/d] Received 95
[39;49m[39;49m[INFO][06/07/2025 15:49:13][Thread 0011][akka://test/user/a/b/c] Received 95
[39;49m[39;49m[INFO][06/07/2025 15:49:13][Thread 0011][akka://test/user/a/b/c] Received 96
[39;49m[39;49m[INFO][06/07/2025 15:49:13][Thread 0011][akka://test/user/a/b/d] Received 96
[39;49m[39;49m[INFO][06/07/2025 15:49:13][Thread 0011][akka://test/user/a/b/d] Received 97
[39;49m[39;49m[INFO][06/07/2025 15:49:13][Thread 0013][akka://test/user/a/b/c] Received 97
[39;49m[39;49m[INFO][06/07/2025 15:49:13][Thread 0013][akka://test/user/a/b/d] Received 98
[39;49m[39;49m[INFO][06/07/2025 15:49:13][Thread 0011][akka://test/user/a/b/c] Received 98
[39;49m[39;49m[INFO][06/07/2025 15:49:13][Thread 0013][akka://test/user/a/b/c] Received 99
[39;49m[39;49m[INFO][06/07/2025 15:49:13][Thread 0011][akka://test/user/a/b/d] Received 99
[39;49m

Cached Result
Last Run:	3:49:11 pm
Compile:	0.392s
Execute:	1.38s
Memory:	42.18Mb
CPU:	1.772s

View IL Code