在Windows服务中以低于正常优先级停止Parallel.ForEach

Question

我的Windows服务中有一个Parallel.ForEach代码。如果ParallelOptions.MaxDegreeOfParallelism设置为-1，我将使用我的大部分CPU。然而，停止服务持续半分钟。应该接收服务应该停止的信号的某些内部控制器线程会超出处理器时间。我将进程优先级设置为低于正常值，但这可能是不相关的信息。

即使所有线程都忙，我还能做些什么来缩短停止服务的时间？

我正在试图暂时降低线程池中线程的优先级，因为我没有任何异步代码，但Internet说这是一个坏主意，所以在这里要求“正确”的方式。

在所有情况下，线程（OS和.NET）在OnStart和OnStop之间都是不同的。此外，如果停止时间非常长，那么最终将调用OnStop的OS线程是一个新线程，而不是在日志中更早显示。

要构建此代码，请创建新的Windows服务项目，从设计器添加ProjectInstaller类，将Account更改为LocalService，然后使用InstallUtil安装一次。确保LocalService可以写入C： Temp。

public partial class Service1 : ServiceBase
{
    private ManualResetEvent stopEvent = new ManualResetEvent(false);
    private Task mainTask;
    private StreamWriter writer = File.AppendText(@"C:TempLog.txt");

    public Service1()
    {
        InitializeComponent();

        writer.AutoFlush = true;
    }

    protected override void OnStart(string[] args)
    {
        Log("--------------");
        Log("OnStart");

        mainTask = Task.Run(new Action(Run));
    }

    protected override void OnStop()
    {
        Log("OnStop");
        stopEvent.Set();

        mainTask.Wait();
        Log("--------------");
    }

    private void Log(string line)
    {
        writer.WriteLine(String.Format("{0:yyyy-MM-dd HH:mm:ss.fff}: [{1,2}] {2}",
            DateTime.Now, Thread.CurrentThread.ManagedThreadId, line));
    }

    private void Run()
    {
        try
        {
            using (var sha = SHA256.Create())
            {
                var parallelOptions = new ParallelOptions();
                parallelOptions.MaxDegreeOfParallelism = -1;

                Parallel.ForEach(Directory.EnumerateFiles(Environment.SystemDirectory),
                    parallelOptions, (fileName, parallelLoopState) =>
                {
                    if (stopEvent.WaitOne(0))
                    {
                        Log("Stop requested");
                        parallelLoopState.Stop();
                        return;
                    }

                    try
                    {
                        var hash = sha.ComputeHash(File.ReadAllBytes(fileName).OrderBy(x => x).ToArray());
                        Log(String.Format("file={0}, sillyhash={1}", fileName, Convert.ToBase64String(hash)));
                    }
                    catch (Exception ex)
                    {
                        Log(String.Format("file={0}, exception={1}", fileName, ex.Message));
                    }
                });
            }
        }
        catch (Exception ex)
        {
            Log(String.Format("exception={0}", ex.Message));
        }
    }
}

Answer 1

另一答案