Лимит одновременных загрузок - PullRequest
Новая
       0

Лимит одновременных загрузок

1 голос
/ 08 сентября 2011

Я делаю асинхронные запросы с WebRequest.BeginGetResponse для загрузки файлов с сервера.Все работает хорошо, но я хочу скачать не более 5 файлов одновременно.В Java я бы использовал фиксированный пул потоков, но я не знаю, как сделать то же самое в C #.Есть идеи? 

class HttpFetcher
{
    public void MakeRequest(Uri uri)
    {
        WebRequest request = WebRequest.Create(uri);
        request.Proxy = null;
        RequestState requestState = new RequestState();
        requestState.Request = request;
        IAsyncResult result = (IAsyncResult) request.BeginGetResponse(new AsyncCallback(ResponseCallback), requestState);

        ThreadPool.RegisterWaitForSingleObject(result.AsyncWaitHandle, new WaitOrTimerCallback(TimeOutCallback), request, 1000, true);
    }

    private void ResponseCallback(IAsyncResult result)
    {
        try
        {
            RequestState requestState = (RequestState)result.AsyncState;
            WebRequest request = requestState.Request;
            requestState.Response = request.EndGetResponse(result);
            Stream responseStream = requestState.Response.GetResponseStream();
            requestState.ResponseStream = responseStream;
            IAsyncResult asynchronousResultRead = responseStream.BeginRead(requestState.BufferRead, 0, 1024, new AsyncCallback(ReadCallback), requestState);
        }
        catch (Exception ex)
        {
            Console.WriteLine("Exception raised!");
            Console.WriteLine("Message : {0}", ex.Message);
            RequestState state = (RequestState)result.AsyncState;
            if (state.Response != null)
                state.Response.Close();
        }

    }

    private void ReadCallback(IAsyncResult result)
    {
        try
        {
            RequestState requestState = (RequestState)result.AsyncState;
            Stream responseStream = requestState.ResponseStream;

            int bytesRead = responseStream.EndRead(result);
            if (bytesRead > 0)
            {
                requestState.RequestData.Append(Encoding.ASCII.GetString(requestState.BufferRead, 0, bytesRead));
                IAsyncResult asynchronousResult = responseStream.BeginRead(requestState.BufferRead, 0, 1024, new AsyncCallback(ReadCallback), requestState);
            }
            else
            {
                Console.WriteLine("\nThe HTML page Contents are:  ");
                if (requestState.RequestData.Length > 1)
                {
                    string sringContent;
                    sringContent = requestState.RequestData.ToString();
                    //Console.WriteLine(sringContent);
                }
                Console.WriteLine("\nPress 'Enter' key to continue........");
                responseStream.Close();
            }
        }
        catch (WebException e)
        {
            Console.WriteLine("WebException raised!");
            Console.WriteLine("\n{0}", e.Message);
            Console.WriteLine("\n{0}", e.Status);
        }
        catch (Exception e)
        {
            Console.WriteLine("Exception raised!");
            Console.WriteLine("Source : {0}", e.Source);
            Console.WriteLine("Message : {0}", e.Message);
        }
    }

    private void TimeOutCallback(object state, bool timedOut)
    {
        if (timedOut)
        {
            WebRequest request = (WebRequest)state;
            if (state != null)
            {
                request.Abort();
            }
        }
    }
}

1 Ответ

1 голос
/ 08 сентября 2011

Вы можете использовать Task.Factory.FromAsync() и использовать Планировщик задач, который ограничивает степень параллелизма

Без погружения в FromAsync(), здесь очень упрощенный пример, которыйпоказывает, что максимум 5 задач выполняются параллельно, независимо от того, сколько в очереди: 

public static void Main()
{
    var scheduler = new LimitedConcurrencyLevelTaskScheduler(5);
    TaskFactory factory = new TaskFactory(scheduler);

    for (int i = 0; i < 50; i++)
    {
        int idx = i;
        var newTask = factory.StartNew(() =>
            {
                Console.WriteLine("Starting " + idx);
                Thread.Sleep(5000);
            });
    }
    Console.ReadLine();
}
...