在C＃中执行并发任务

我有一项服务，需要尽快读取来自Amazon SQS的消息。我们期望流量很大，我希望能够每秒读取1万条以上的消息。不幸的是，我目前每秒大约有10条消息。显然，我有工作要做。

这就是我正在使用的（转换为控制台应用程序以简化测试）：

private static int _concurrentRequests;
private static int _maxConcurrentRequests;

public static void Main(string[] args) {
    _concurrentRequests = 0;
    _maxConcurrentRequests = 100;

    var timer = new Timer();
    timer.Elapsed += new ElapsedEventHandler(OnTimedEvent);
    timer.Interval = 10;
    timer.Enabled = true;

    Console.ReadLine();
    timer.Dispose();
}

public static void OnTimedEvent(object s, ElapsedEventArgs e) {
    if (_concurrentRequests < _maxConcurrentRequests) {
        _concurrentRequests++;
        ProcessMessages();
    }
}

public static async Task ProcessMessages() {
    var manager = new MessageManager();
    manager.ProcessMessages();  // this is an async method that reads in the messages from SQS

    _concurrentRequests--;
}

我没有收到接近100个并发请求，而且似乎也不是OnTimedEvent每10毫秒触发一次。

我不确定Timer这里是否正确。我对这种编码没有太多的经验。我愿意在这一点上尝试任何事情。

更新

多亏了calebboyd，我才更接近实现自己的目标。这是一些非常糟糕的代码：

private static SemaphoreSlim _locker;

public static void Main(string[] args) {
    _manager = new MessageManager();

    RunBatchProcessingForeverAsync();
}
private static async Task RunBatchProcessingForeverAsync() {
    _locker = new SemaphoreSlim(10, 10);
    while (true) {
        Thread thread = new Thread(new ParameterizedThreadStart(Process));
        thread.Start();
    }
}

private static async void Process(object args) {
    _locker.WaitAsync();
    try {
        await _manager.ProcessMessages();
    }
    finally {
        _locker.Release();
    }

}

这样我可以接近每秒读取大量消息，但是问题是我的ProcessMessages通话永远都无法结束（或者可能会在很长一段时间后结束）。我想我可能需要限制我一次运行的线程数。

关于如何改进此代码，以便ProcessMessages有机会完成的任何建议？