在 Windows 服务中运行长时间运行的任务

Question

我编写了一个 Windows 服务项目，该项目托管一个长时间运行的消息泵任务，该任务旨在在服务期间运行。当服务启动时，它会启动任务。当服务停止时，它会停止任务：

void OnStart()
{
    MessagePump.Start();
}

void OnStop()
{
    MessagePump.Stop();
}

MessagePump.Start 执行 Task.Factory.StartNew，MessagePump.Stop 指示任务停止并执行 Wait()。

到目前为止一切都很好，但我想知道如何最好地处理错误。如果任务有未处理的异常，我希望服务停止，但由于通常没有等待任务，我想它只会坐在那里什么都不做。我该如何优雅地处理这种情况？

更新：

共识似乎是使用'await'或ContinueWith。以下是我目前编写 Start 方法以使用它的方式：

public async static void Start()
{
    this.state = MessagePumpState.Running;
    this.task = Task.Factory.StartNew(() => this.ProcessLoop(), TaskCreationOptions.LongRunning);
    try
    {
        await this.task;
    }
    catch
    {
        this.state = MessagePumpState.Faulted;
        throw;
    }
}

Answer 1

让你 MessagePump.Start() 方法返回任务。那么

MessagePump.Start().ContinueWith(t => 
{
    // handle exception 
}, 
TaskContinuationOptions.OnlyOnFaulted);

更新： 我会做下一个：

private MessagePump _messagePump;

async void OnStart()
{
    this._messagePump = new MessagePump();
    try
    {
        // make Start method return the task to be able to handle bubbling exception here
        await _messagePump.Start();
    }
    catch (Exception ex)
    {
        // log exception
        // abort service
    }
}

void OnStop()
{
    _messagePump.Stop();
}

public enum MessagePumpState
{
    Running,
    Faulted
}

public class MessagePump
{
    private CancellationTokenSource _cancallationTokenSrc;
    private MessagePumpState _state;
    public async Task Start()
    {
        if (_cancallationTokenSrc != null)
        {
            throw new InvalidOperationException("Task is already running!");
        }

        this._state = MessagePumpState.Running;
        _cancallationTokenSrc = new CancellationTokenSource();
        var task = Task.Factory.StartNew(() => this.ProcessLoop(_cancallationTokenSrc.Token), _cancallationTokenSrc.Token);
        try
        {
            await task;
        }
        catch
        {
            this._state = MessagePumpState.Faulted;
            throw;
        }
    }

    public void Stop()
    {
        if (_cancallationTokenSrc != null)
        {
            _cancallationTokenSrc.Cancel();
            _cancallationTokenSrc = null;
        }
    }

    public void ProcessLoop(CancellationToken token)
    {
        // check if task has been canceled
        while (!token.IsCancellationRequested)
        {
            Console.WriteLine(DateTime.Now);
            Thread.Sleep(1000);
        }
    }
}

Answer 2

你可以试试这样的：

void OnStart()
{
    MessagePump.StartAsync(); 
    MessagePump.ErrorEvent += OnError();
}

然后您的 StartAsync 将如下所示：

public async Task StartAsync()
{
     // your process
     // if error, send event to messagePump
}

如果您决定使用 Tasks，那么最好使用 Task.Run 而不是 Task.Factory.StartNew()