CODEWITHSUNDEEP
c#wait
Murdej Ukrutný
Murdej Ukrutný

Reputation: 339

Wait for callback

I have a service that receives requests and processes them gradually (using ActionBlock).

Sometimes I need to wait until it's processed. I have the option to enter a callback. Is there a way to pause the run until a callback is called?

Something like this, but better:

    bool complete = true;
    service.AddRequest(new ServiceRequest()
    {
        OnComplete = (req) =>
        {
            complete = true;
        }
    });
    while (!complete) Thread.Sleep(100);

Longer code for context:

public class Service
{
    protected ActionBlock<ServiceRequest> Requests;
    public Service()
    {
        Requests = new ActionBlock<ServiceRequest>(req => {
            // do noting
            Thread.Sleep(1000);
            req.OnComplete?.Invoke(req);
        });
    }

    public void AddRequest(ServiceRequest serviceRequest) => Requests.Post(serviceRequest);
}

public class ServiceRequest
{
    public Action<ServiceRequest> OnComplete;
    string Foo;
}

public class App
{
    public static void Start()
    {
        var service = new Service();
        service.AddRequest(new ServiceRequest());
        // I need to wait for processing

        // smelly code!!
        bool complete = true;
        service.AddRequest(new ServiceRequest()
        {
            OnComplete = (req) =>
            {
                complete = true;
            }
        });
        while (!complete) Thread.Sleep(100);
        // smelly code!! end
    }
}

Upvotes: 1

Views: 271

Answers (1)

VillageTech
VillageTech

Reputation: 2015

There is mistake in your code, the initial value of complete should be false ;)

bool complete = false; // initial value
service.AddRequest(new ServiceRequest()
{
    OnComplete = (req) =>
    {
        complete = true;
    }
});
while (!complete) Thread.Sleep(100);

To prevent active waiting in loop you can use the AutoResetEvent:

AutoResetEvent completedEv = new AutoResetEvent();
service.AddRequest(new ServiceRequest()
{
    OnComplete = (req) =>
    {
        completedEv.Set();
    }
});

completedEv.WaitOne();

NOTE: the AutoResetEvent implements IDisposable interface, so you have to be sure that it will be disposed even in error situations.

Upvotes: 2

Related Questions