How to run background process in asp.net core 2.0

Hi all,

i am developing an application in asp.net core 2.0 where i am facing an issue thing is that user is uploading excel which contains 50000 thounsand records or even more here over all concept is that after uploading excel data i am saving in table a with all in one shot by using AddRange of entityframework core now after this i have to create two master table from this table now thing is that i want to enter data in these two table by background process but have no clue how to do it please give me any suggestion

Hello Ashish,

You can use "QueueBackgroundWorkItem" class to background tasks in hosted .net core service.

Below is the sample code snippet.

public interface IBackgroundTaskQueue
{
void QueueBackgroundWorkItem(Func workItem);
Task> DequeueAsync(
CancellationToken cancellationToken);
}
public class BackgroundTaskQueue : IBackgroundTaskQueue
{
private ConcurrentQueue> _workItems =
new ConcurrentQueue>();
private SemaphoreSlim _signal = new SemaphoreSlim(0);
public void QueueBackgroundWorkItem(
Func workItem)
{
if (workItem == null)
{
throw new ArgumentNullException(nameof(workItem));
}
_workItems.Enqueue(workItem);
_signal.Release();
}
public async Task> DequeueAsync(
CancellationToken cancellationToken)
{
await _signal.WaitAsync(cancellationToken);
_workItems.TryDequeue(out var workItem);
return workItem;
}
}

services.AddSingleton();

Hope, this will help you out.

1 Reply

Know the answer? Post it — somebody with the same question will find it here.

Tejas Trivedi8y ago
Accepted answer
Hello Ashish,

You can use "QueueBackgroundWorkItem" class to background tasks in hosted .net core service.

Below is the sample code snippet.
public interface IBackgroundTaskQueue
{
    void QueueBackgroundWorkItem(Func workItem);

    Task> DequeueAsync(
        CancellationToken cancellationToken);
}

public class BackgroundTaskQueue : IBackgroundTaskQueue
{
    private ConcurrentQueue> _workItems =
        new ConcurrentQueue>();
    private SemaphoreSlim _signal = new SemaphoreSlim(0);

    public void QueueBackgroundWorkItem(
        Func workItem)
    {
        if (workItem == null)
        {
            throw new ArgumentNullException(nameof(workItem));
        }

        _workItems.Enqueue(workItem);
        _signal.Release();
    }

    public async Task> DequeueAsync(
        CancellationToken cancellationToken)
    {
        await _signal.WaitAsync(cancellationToken);
        _workItems.TryDequeue(out var workItem);

        return workItem;
    }
}

services.AddSingleton();
Hope, this will help you out.
+1