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
and as a general rule, you should never touch actor state from threads other than what the actor is running on
but in this case, some services lives only that the scope defined by that call, that's why I used that.
it just wraps the call with a scope
