Синхронизация потоков c#

@GooG2e · Регистрация: 13.06.2011

Студворк — интернет-сервис помощи студентам

Всем привет)
Решил написать программу, которая в несколько потоков будет выкачивать торрент файлы с трекера, но возникла проблема - в какой-то момент все потоки могут зависнуть(ну или они подходят к зависанию, а я по последнему замечаю)
Примерный алгоритм работы программы такой - сначала обрабатываются страницы и данные о торренте, который нужно выгрузить заносятся в очередь. Одновременно с этим запускаются m потоков, которые начинают выкачивать торренты постепенно опустошая очередь. Чтобы не происходило ошибок в момент считывания из очереди и проверки наличия там элементов очередь блокируется.
Для блокировки использовал lock, monitor, mutex,но везде была проблема с зависанием.

P.S.можете посоветовать как решить проблему?

@Tessen · 16.04.2013, 09:06

какой то поток хватает блокировку и не отдает, все остальные ждут вечно
могу посоветовать расставить блокировки так чтобы взаимной блокировки не происходило

@GooG2e · 16.04.2013, 09:08 **[ТС]**

Сообщение от Tessen

какой то поток хватает блокировку и не отдает, все остальные ждут вечно
могу посоветовать расставить блокировки так чтобы взаимной блокировки не происходило

В том то и дело, что снятие блокировки четко прописано(блокировка перед блоком try , код и разблокировка в finally)

@Tessen · 16.04.2013, 09:10

видимо недостаточно точно
вариант №1 - где то косяк в самом коде потока и он виснет намертво сам по себе. запускаешь поток только один и смотришь зависнет или нет, если нет см. п2
вариант №2 - где то у тебя есть взаимная блокировка

@GooG2e · 16.04.2013, 09:20 **[ТС]**

В первом варианте сомневаюсь т.к. он может на одних и тех же данных зависнуть и на тысячном файле, а может и на четырехтысячном файле зависнуть+никаких ошибок он не выдает.

Код блокировки вот такой:

C#
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
//Monitor.TryEnter(downloads,Timeout.Infinite);
                mtx.WaitOne();
                try
                {
                    if (downloads.Count != 0)
                    {
                        cur = downloads.Dequeue();
                    }
                    else
                    {
                        continue;
                    }
                }
                finally
                {
                    //Monitor.Exit(downloads);
                    mtx.ReleaseMutex();
                }

Блокировка необходима только в этом месте.

@Tessen · 16.04.2013, 09:28

почему бы вам не поставить таймаут отличный от бесконечности в закомментированной блокировке и не посмотреть получает он ее или ждет полчаса и более (виснет намертво)?
з.ы только ли в этом? а добавление в очередь?

@GooG2e · 16.04.2013, 09:56 **[ТС]**

Сообщение от Tessen

почему бы вам не поставить таймаут отличный от бесконечности в закомментированной блокировке и не посмотреть получает он ее или ждет полчаса и более (виснет намертво)?
з.ы только ли в этом? а добавление в очередь?

Таймаут стоит не на блоировку, а как я понял, на ожидание блокировки т.е. если переменная заблокирована, то столько её ждать, к тому же с Mutex, который не закомментирован происходит тоже самое

P.S.Добавление в очередь как показала практика в блокировке не нуждается - все спокойно добавляется и как раз тут зависаний нет.

@Tessen · 16.04.2013, 10:02

именно на ожидание блокировки - сколько у вас поток должен ждать? извлечение из очереди быстрая операция, думаю если вы поставите таймаут 30 секунд то
А) у вас все в порядке с блокировками, таймаут не вылетит никогда
Б) у вас таки где то есть взаимная блокировка, поздравляю

@GooG2e · 16.04.2013, 10:23 **[ТС]**

Сообщение от Tessen

именно на ожидание блокировки - сколько у вас поток должен ждать? извлечение из очереди быстрая операция, думаю если вы поставите таймаут 30 секунд то
А) у вас все в порядке с блокировками, таймаут не вылетит никогда
Б) у вас таки где то есть взаимная блокировка, поздравляю

Ставлю таймаут 30 секунд( а особенно заметно, если меньше 30 секунд), то начинает вылетать ошибка, что я пытаюсь разблокировать заблокированный элемент(блокировать больше некому - может на каких-то операциях автоматически происходит блокировка??)

Если ставить блокировку и на запись в очередь, то происходят ещё более странные вещи - ошибки вылазят в самых непонятных местах и непонятно почему....

Новые блоги и статьи Все статьи Все блоги /
Как дизайн сайта влияет на конверсию: 7 решений, которые реально повышают заявки Neotwalker 08.03.2026 Многие до сих пор воспринимают дизайн сайта как “красивую оболочку”. На практике всё иначе: дизайн напрямую влияет на то, оставит человек заявку или уйдёт через несколько секунд. Даже если у вас. . .	Модульная разработка через nuget packages DevAlt 07.03.2026 Сложившийся в . Net-среде способ разработки чаще всего предполагает монорепозиторий в котором находятся все исходники. При создании нового решения, мы просто добавляем нужные проекты и имеем. . .	Модульный подход на примере F# DevAlt 06.03.2026 В блоге дяди Боба наткнулся на такое определение: В этой книге («Подход, основанный на вариантах использования») Ивар утверждает, что архитектура программного обеспечения — это структуры,. . .	Управление камерой с помощью скрипта OrbitControls.js на Three.js: Вращение, зум и панорамирование 8Observer8 05.03.2026 Содержание блога Финальная демка в браузере работает на Desktop и мобильных браузерах. Итоговый код: orbit-controls-threejs-js. zip. Сканируйте QR-код на мобильном. Вращайте камеру одним пальцем,. . .
SDL3 для Web (WebAssembly): Синхронизация спрайтов SDL3 и тел Box2D 8Observer8 04.03.2026 Содержание блога Финальная демка в браузере. Итоговый код: finish-sync-physics-sprites-sdl3-c. zip На первой гифке отладочные линии отключены, а на второй включены:. . .	SDL3 для Web (WebAssembly): Идентификация объектов на Box2D v3 - использование userData и событий коллизий 8Observer8 02.03.2026 Содержание блога Финальная демка в браузере. Итоговый код: finish-collision-events-sdl3-c. zip Сканируйте QR-код на мобильном и вы увидите, что появится джойстик для управления главным героем. . . .	Реалии Hrethgir 01.03.2026 Нет, я не закончил до сих пор симулятор. Эта задача сложнее. Не получилось уйти в плавсостав, но оно и к лучшему, возможно. Точнее получалось - но сварщиком в палубную команду, а это значит, в моём. . .	Ритм жизни kumehtar 27.02.2026 Иногда приходится жить в ритме, где дел становится всё больше, а вовлечения в происходящее — всё меньше. Плотный график не даёт вниманию закрепиться ни на одном событии. Утро начинается с быстрых,. . .

@GooG2e 0 / 0 / 0 Регистрация: 13.06.2011 Сообщений: 41

	Синхронизация потоков c# 16.04.2013, 08:59. Показов 2520. Ответов 8 Метки нет (Все метки) Всем привет) Решил написать программу, которая в несколько потоков будет выкачивать торрент файлы с трекера, но возникла проблема - в какой-то момент все потоки могут зависнуть(ну или они подходят к зависанию, а я по последнему замечаю) Примерный алгоритм работы программы такой - сначала обрабатываются страницы и данные о торренте, который нужно выгрузить заносятся в очередь. Одновременно с этим запускаются m потоков, которые начинают выкачивать торренты постепенно опустошая очередь. Чтобы не происходило ошибок в момент считывания из очереди и проверки наличия там элементов очередь блокируется. Для блокировки использовал lock, monitor, mutex,но везде была проблема с зависанием. P.S.можете посоветовать как решить проблему? 0

@Tessen 713 / 680 / 126 Регистрация: 30.03.2012 Сообщений: 1,124
	16.04.2013, 09:06
	какой то поток хватает блокировку и не отдает, все остальные ждут вечно могу посоветовать расставить блокировки так чтобы взаимной блокировки не происходило 0

@Tessen 713 / 680 / 126 Регистрация: 30.03.2012 Сообщений: 1,124
	16.04.2013, 09:10
	видимо недостаточно точно вариант №1 - где то косяк в самом коде потока и он виснет намертво сам по себе. запускаешь поток только один и смотришь зависнет или нет, если нет см. п2 вариант №2 - где то у тебя есть взаимная блокировка 0

@Tessen 713 / 680 / 126 Регистрация: 30.03.2012 Сообщений: 1,124
	16.04.2013, 09:28
	почему бы вам не поставить таймаут отличный от бесконечности в закомментированной блокировке и не посмотреть получает он ее или ждет полчаса и более (виснет намертво)? з.ы только ли в этом? а добавление в очередь? 0

@Tessen 713 / 680 / 126 Регистрация: 30.03.2012 Сообщений: 1,124
	16.04.2013, 10:02
	именно на ожидание блокировки - сколько у вас поток должен ждать? извлечение из очереди быстрая операция, думаю если вы поставите таймаут 30 секунд то А) у вас все в порядке с блокировками, таймаут не вылетит никогда Б) у вас таки где то есть взаимная блокировка, поздравляю 0