将 StreamWriter 传递给另一个线程并在 N 秒后关闭该线程

Question

我有这样的代码：

StreamWriter successWriter = File.AppendText(pathSuccess);
task = Task.Factory.StartNew(() =>
{
    IEnumerable<string> lines = File
          .ReadLines(actualPath)
          .Skip(GetInt(positionNumericUpDown.Value));
    try
    {
        var options = new ParallelOptions()
        {
            CancellationToken = cts.Token,
            MaxDegreeOfParallelism = GetInt(maxThreadNumericUpDown.Text)
        };

        Parallel.ForEach<string>(lines, options, (line, loopState, idx) =>
        {
            options.CancellationToken.ThrowIfCancellationRequested();
            Result result = getResult(line);
            lock(successWriter)
            {
               successWriter.WriteLine("{0}\t{1}", result.Url, result.Message);
               successWriter.Flush();
            }
        }
    }
    catch (OperationCanceledException ex)
    {
        Console.WriteLine(ex.Message);
    }
},
TaskCreationOptions.LongRunning);

现在我需要每 60 秒启动另一个线程 NewThread 使用方法

 void checkForMoreResults(successWriter);

NewThread 可能需要超过 60 秒，所以我需要在开始之前关闭以前运行的线程新的（每 60 秒后）

任何建议我该怎么做将不胜感激

Answer 1

为什么不直接使用 BackgroundWorker 并调用 CancelAsync() 呢？它可能比 .net TPN API 更容易一些。