I created a service with a queue of messages
the actors should pop some messages from time to time
yes!
that's the point!
I created some actors using the async behaviour
s/them/the messages
the Executors is a pool of actors routed by the monitor
ok
if I use the async from the .NET then the actors does not respect the default behaviour that only one message is processed by an actor at a time, apparenly
apparently*
is the the right thing when using async or a problem
just checking
yes, I configured that
kkkkkkkkkkkkk
is there another one here?
are you using ReceiveActor?
I will write one example here, just a moment
the default behavior is Suspend already
in 1.0.1
me too
and good to say that was not a problem with me this time
:D
public class JobExecutor : ReceiveActor
{
private readonly Application _application;
private bool _working = false;
public JobExecutor(Application application)
{
_application = application;
Receive<BeginWork>(AsyncBehavior.Reentrant, _ => _application.ExecuteInScope(() => OnBeginWork()));
}
private async Task OnBeginWork()
{
if (_working)
{
Console.WriteLine("Executando trabalho ainda {0}", Thread.CurrentThread.ManagedThreadId);
return;
}
_working = true;
Console.WriteLine("Iniciando trabalho {0}", Thread.CurrentThread.ManagedThreadId);
//Thread.Sleep(8000);
await Task.Delay(10000);
Console.WriteLine("Finalizando trabalho {0}", Thread.CurrentThread.ManagedThreadId);
_working = false;
}
}
you want the non-reentrant behavior