Почему «блокируется» второй поток при попытке http-request?

Question

[Михаил]

Здравствуйте. Есть метод для отправки запросов:

public static XDocument _request(string Url)
{
     WebRequest Request = WebRequest.Create(Url);
     Stream XmlStream = Request.GetResponse().GetResponseStream();
     return XDocument.Load(XmlStream);
}

Пытаюсь запустить два потока:

foreach (string Link in Links)
{
    TimerCallback RSSCallback = new TimerCallback(ReadRSS);
    Timer Timer = new Timer(Test, Link, 0, 3000);
}

public static void Test(object obj)
{ 
    string Url = (string)obj;
    Console.WriteLine($"Запрос на {Url}");
    RSS._request(Url);
}

В итоге вижу следующее:

То есть по какой-то причине запросы начинают обрабатывать только в одном потоке, в другом всё тихо. Опытным путём выяснил, что это никак не зависит от URL. То есть если поменять в массиве Links элементы, то всё равно только первый поток работает.

В чём ошибка?

UPD. Опытным путём было выявлено, что ошибка в строчке return XDocument.Load(XmlStream). Если её убрать, то все запросы нормально отправляются на оба ресурсов без каких-либо проблем

Comments

[ProTreo]

Предположение:

TimerCallback при создании таймера создает поток в ThreadPool. А там по сути существует очередь для выполнения, которую вы забиваете. У вас попросту кончается место в ThreadPool, поэтому коллбэки начинают исполняться медленно друг за другом.

Погуглив можно найти советы в стиле - Timeout.Infinite для двух последних параметров при создании Timer и использование Timer.Change с Timeout.Infinite непосредственно в колбэке самой последней строчкой - таким образом в вашем случае не создастся к примеру 100 заданий в очереди к ThreadPool на обращение к определенному ресурсу, а таймеры будут рестартовать после завершения.

Сейчас у вас если до ресурса за 3 секунды не достучатся - колбэк не успевает выполнится и создается 2, 3 и 4... колбэки и так до бесконечности. Представьте что будет если какой-нибудь ресурс отвалится с 404 ошибкой к примеру, или вы будете слать много запросов и сервак зафорсит разрыв соединения с вами или же самый худший вариант :) Истощение портов(port exhaustion) на вашем компе, когда у вас все повиснет в FIN_WAIT2 или CLOSE_WAIT - у вас останутся висеть открытые сокеты и некуда будет получать ответ, короче тлен.

Ограничивайте многопоточность, попробуйте увеличить минимальное кол-во потоков для ThreadPool через метод ThreadPool.SetMinThreads (но они таким образом всеравно кончатся), обрабатывайте ошибки доступа к ресурсам, чтобы программа не падала и не используйте ThreadPool. Меньше головной боли.

[Михаил]

ProTreo, Беда в том, что и при увеличении периода таймер с трёх секунд до одной минуты проблема сохраняется. Неужели я и за одну минуту не успеваю получить ответ от ресурса?

Я думал переделать на DispatcheTimer (он в главном потоке работает асинхронно), но подумал, что это будет менее производительно.

Что касается обработки ошибок, то у меня стоит try/catch, просто решил не захламлять тут пример лишними конструкциями.

[Михаил]

ProTreo, Я ещё тут совсем странную вещь обнаружил. Вся загвоздка в этой строчке:
return XDocument.Load(XmlStream);
Если выкинуть её из метода Test, то запросы нормально отправляются на оба ресурса. Но теперь я совсем не понимаю, в чём ошибка.

И ещё обнаружил, что обрабатываться остаётся только последним элемент в массиве

Более того, всё работает, если не перебирать массив, а ручками написать:

Timer t1 = new Timer(Test, Links[0], 0, 3000);
Timer t2 = new Timer(Test, Links[1], 0, 3000);

[ProTreo]

Михаил, Еще может быть момент с тем, что у вас не хранятся референсы на таймеры. Я когда выполнял ваш код - клал каждый таймер в лист.

[Михаил]

ProTreo, после длительных экспериментов пришёл к выводу, что это GC убивает мои таймеры. Боеле того, нашёл сноску на MSDN:

As long as you are using a Timer, you must keep a reference to it. As with any managed object, a Timer is subject to garbage collection when there are no references to it. The fact that a Timer is still active does not prevent it from being collected.

[Михаил]

ProTreo, Спасибо большое за помощь!

Answer 1

[Александр Юдаков]

Не очень понимаю, зачем все эти Timer и TimerCallback.
Если надо просто запустить несколько запросов параллельно, предлагаю этот код:

TimerCallback RSSCallback = new TimerCallback(ReadRSS);
Timer Timer = new Timer(Test, Link, 0, 3000);

заменить вот этим:
new Task(Test, Link).Start();

Comments

[Михаил]

Мне нужно отправлять запросы каждые n минут, поэтому таймеры нужны в любом случае. А этот код отправит запрос единожды