1

Как я могу создать очередь потоков, что бы они выполнялись в каком-то пуле по 50 штук, например ? То есть одновременно выполнялось 50 каких-то тасков и как только один из них закончился, из очереди брался следующий и так пока вся очередь не закончится.

3
  • можно создать наследника класса TaskScheduler и в нем управлять Thread'ами для выполнения Task'ов.
    – Stack
    7 фев 2016 в 15:00
  • пример реализации наследника TaskScheduler см. ThreadPoolTaskScheduler -- используется по-умолчанию при работе с Task'ами.
    – Stack
    7 фев 2016 в 15:07
  • Вы не поверите, но именно так и устроен стандартный thread pool.
    – VladD
    7 фев 2016 в 16:35

1 ответ 1

1

Подобный функционал можно реализовать при помощи семафоров.

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

3
  • У меня очередь на 30 тысяч задач и из-за этого кидает Out of memory эксепшен. Как в таком случае быть ?
    – Neustart
    7 фев 2016 в 21:01
  • 2
    Если в двух словах, то выполнить оптимизацию. Но, как это сделать, тема заслуживающая отдельного разговора. Вероятнее всего изначальный вопрос и семафоры сами по себе здесь вообще не при чём. ИМХО, в данном случае, лучше всего задать отдельный вопрос с подробным описанием как Вы создаёте эту очередь и как Вы с ней работаете. Тогда, Вам смогут как-то здесь помочь.
    – Streletz
    7 фев 2016 в 21:13
  • 1
    @Neustart: об этом действительно лучше задать отдельный вопрос. В нём расскажите не только что вы делаете, но — прежде всего — какую задачу таким способом решаете. Возможно, вам предложат более оптимальные пути решения.
    – Nick Volynkin
    9 фев 2016 в 6:20

Ваш ответ

By clicking “Отправить ответ”, you agree to our terms of service and acknowledge you have read our privacy policy.

Всё ещё ищете ответ? Посмотрите другие вопросы с метками или задайте свой вопрос.