c# - Threading.Timer 在控制台应用程序中停止

Question

我正在使用包含 ID 作为键和队列作为值的字典。我有一个线程写入队列，另一个线程从队列读取，所以我需要使用 .NET 4.0 中引入的并发结构。作为其中的一部分，我尝试编写一个测试应用程序来填充队列，但我遇到了一个问题，即计时器在大约 10 秒后停止。我真的不明白为什么，因为没有什么可捕获的，没有错误消息或任何提示我可能出了什么问题。

有人可以向我解释为什么计时器在大约 10 秒后停止吗？我在两台不同的计算机上尝试过此操作(均使用 Visual Studio 2012，但使用 .NET Framework 4.0)。

class Program {

    private readonly ConcurrentDictionary<int, ConcurrentQueue<TestObject>> _pipes = 
        new ConcurrentDictionary<int, ConcurrentQueue<TestObject>>();

    static void Main() {
        Program program = new Program();
        program.Run();
        Console.Read();
    }

    private void Run() {
        _pipes[100] = new ConcurrentQueue<TestObject>();
        _pipes[200] = new ConcurrentQueue<TestObject>();
        _pipes[300] = new ConcurrentQueue<TestObject>();

        Timer timer = new Timer(WriteStuff, null, 0, 100);
    }

    private void WriteStuff(object sender) {
        for (int i = 0; i < 5; i++) {
            foreach (KeyValuePair<int, ConcurrentQueue<TestObject>> pipe in _pipes) {
                pipe.Value.Enqueue(
                    new TestObject { Name = DateTime.Now.ToString("o") + "-" + i });
            }
            i++;
        }
        Console.WriteLine(DateTime.Now + "added stuff");
    }
}

internal class TestObject {
    public string Name { get; set; }
    public bool Sent { get; set; }
}

Answer 1

很可能，计时器超出范围并被收集。在外部范围声明定时器。即:

private Timer timer;
private void Run()
{
    ...
    timer = new Timer(WriteStuff, null, 0, 100);
}

另外，我想你会发现 BlockingCollection比 ConcurrentQueue 更容易使用。 BlockingCollection 围绕并发集合包装了一个非常好的 API，使得在删除内容时更容易在队列上进行非繁忙等待。在其默认配置中，它使用 ConcurrentQueue 作为后备存储。要使用它，您只需将代码中的 ConcurrentQueue 替换为 BlockingCollection，并将调用 Enqueue 更改为调用 Add。如:

for (int i = 0; i < 5; i++)
{
    foreach (var pipe in _pipes)
    {
        pipe.Value.Add(
            new TestObject { Name = DateTime.Now.ToString("o") + "-" + i });
    }
}