信号量包装方法

Question

基于一些关于SO的问题，主要是这个： Throttling asynchronous tasks

我已经实现了 SemaphoreSlim 对象，以便通过我的应用程序中的一系列方法同时处理请求。这些方法中的大多数都在获取 ID 列表，并以并发方式从 Web 获取每个 ID 的单字节数组。实现如下所示：

 using (var semaphore = new SemaphoreSlim(MaxConcurrency))
                {
                    var tasks = fileMetadata.GroupBy(x => x.StorageType).Select(async storageTypeFileMetadata=>
                    {
                        await semaphore.WaitAsync();
                        try
                        {
                            var fileManager = FileManagerFactory.CreateFileManager((StorageType)storageTypeFileMetadata.Key);
                            await fileManager.UpdateFilesAsync(storageTypeFileMetadata);
                        }
                        finally
                        {
                            semaphore.Release();
                        }
                    });

                    await Task.WhenAll(tasks);
                }

有没有办法为信号量代码抽象出一个方法或者一些可重用的代码sn-p，把我需要做的工作传进去，这样就可以重复使用而无需每次都重新编写信号量代码？使用相同信号量模式的多个方法之间的唯一区别是我正在迭代的列表以及它在 try{} 中所做的工作。

我正在考虑类似将 list.select(x=> my task method with my work in it) 传递给一个信号量方法，该方法是所有包装信号量代码。

Answer 1

所以我猜是这样的：

public static class Extension
{
    public static async Task ExecuteAsync<T>(this IEnumerable<T> items, Func<T, Task> task, int concurrency)
    {
        var tasks = new List<Task>();

        using (var semaphore = new SemaphoreSlim(concurrency))
        {
            foreach (var item in items)
            {
                tasks.Add(ExecuteInSemaphore(semaphore, task, item));
            }

            await Task.WhenAll(tasks);
        }
    }

    private static async Task ExecuteInSemaphore<T>(SemaphoreSlim semaphore, Func<T, Task> task, T item)
    {
        await semaphore.WaitAsync();

        try
        {
            await task(item);
        }
        finally
        {
            semaphore.Release();
        }
    }
}

然后你会像这样使用它：

await fileMetadata.GroupBy(x => x.StorageType).ExecuteAsync(storageTypeFileMetadata =>
{
    var fileManager = FileManagerFactory.CreateFileManager((StorageType)storageTypeFileMetadata.Key);
    return fileManager.UpdateFilesAsync(storageTypeFileMetadata);
}, 4);