Comments by Ashish Singh Feb2022

Ashish Singh Feb2022 27-Feb-22 4:09am View

Its hard to debug service especially with sockets, I created a simple test program with async/await method implementation to test the concept and it looks like it works.
I know you've provided Cancellation example but I'm condfused how would I implement that in a service application.

Ashish Singh Feb2022 25-Feb-22 19:58pm View

Ok. I'm going through your videos right now.

Ashish Singh Feb2022 25-Feb-22 19:29pm View

Good morning.

ListenForStatus is already on its own thread spun up from service OnStart method. Why do I need to make it async. And yes, there is loop inside ListenForStatus that just waits for the service to stop

private void ListenForStatus(){    ...    while (!_shutdownEvent.WaitOne(0))    {        ....        ProcessEventAsync(stringData);    }}

Isn't it the ProcessEvent that needs to be async as I need Task.Delay there?

private async Task ProcessEventAsync(string Status){    ...    await Task.Delay(TimeSpan.FromSeconds(30));    //Do something}

Also, how do I handle Cancellation if the service is stopped? Where do I initialize the CancellationTokenSource object and how I cancel it from onStop() method ?

Ashish Singh Feb2022 25-Feb-22 8:00am View

Thanks. I’ll look into it. It’s getting late out here. Have a nice weekend.

Ashish Singh Feb2022 25-Feb-22 7:44am View

I understand with the await operator, StateMachine is spun up and this is what gives a sense of multi-threading operation. What I don’t understand is if my calling method (ListenForStatus) will continue to process incoming tcp streams while the ProcessEventsAsync awaits on Task.Delay (which apparently spins up a new thread). I think I’m just cutting some slack asking around instead of testing it myself. I’ll check out the videos you posted, thanks again.

Ashish Singh Feb2022 25-Feb-22 7:10am View

Ok thanks. I’m just looking for some confirmation that async/await will not block tcp stream in the pipeline while processing the one in hand. Also, I need a way to cancel all async tasks if the service is stopped (on stop method) - where would I declare cancel token etc . I’m new to this site so am not particularly familiar with creating projects and such. But I’ll look into it. Thanks for your support though.

Ashish Singh Feb2022 25-Feb-22 2:50am View

Thanks @Graeme_Grant.

If I make the ProcessEvent method an async method ProcessEventAsync, will the method block the execution of the whole program for 30 seconds or just its instance? I would like ListenForStatus() method to call new instance of ProcessEventAsync whenever there is a new TCP stream. Every ProcessEventAsync will await 30 second before "Doing Something"

protected override void OnStart(string[] args)
{
    ...
    worker = new Thread(ListenForStatus);
    worker.Start();
}
private void ListenForStatus()
{
    ...
    client = new TcpClient();
    client.Connect(new IPEndPoint(IPAddress.Parse(IPADDR), PORT));
    using (NetworkStream stream = client.GetStream())
    {
        int numBytesRead = stream.Read(data, 0, data.Length);
            if (numBytesRead > 0)
            {
                ...
                ProcessEventAsync(stringData);
            }
    }
}

private async Task ProcessEventAsync(string Status)
{
    await Task.Delay(TimeSpan.FromSeconds(30));
    // Do something
}

Ashish Singh Feb2022 22-Feb-22 3:41am View

I’m not looking for blocking call. I still need the service to execute instructions in between.

Comments by Ashish Singh Feb2022 (Top 8 by date)