Как ограничить количество одновременно запускаемых потоков?

Question

[Xveeder]

Доброго времени суток, товарищи.

Возник вопрос. Например, у меня есть 100 определённых сущностей, которые выполняют определённые действия. Я хочу запустить их в многопотоке, но чтобы одновременно работало не более 15 потоков, и в то время, когда определённая сущность вышла из потока (т.е. выполнила свой таск), в этот поток зашла сразу новая.

Как это сделать (при работе с thread)? На первый взгляд, наиболее простым методом является семафор. Но правильно ли?
Спасибо.

Comments

[tex0]

Тот механизм который вы описываете называется thread pool. В .Net уже есть его реализация, просто пользуйтесь ей

[Xveeder]

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

for (int i = 0; i < 15; i++)
            {
               
                ThreadPool.QueueUserWorkItem(new WaitCallback(Worker), i);
                
            }

То он выполнение этих 15 итераций выстраивает в максимально возможное количество потоков?

[tex0]

Xveeder, пожалуйста.
Посмотрите какой функционал есть у этого класса. Там есть метод, который ограничивает количество одновременно выполняющихся потоков. SetMaxThreads по моему он называется. Устанавливаете им количество потоков и вуаля. Если все слоты под потоки будут заняты исполнением процедур, то остальные кандидаты на выполнение (new WaitCallback(Worker)) будут выстраиваться в очередь, вот и всё.

Answer 1

[basrach]

Самый простой вариант это использовать Parallel.Foreach.

var myEntities = new MyEntity[100];
var maxThreads = 15;

System.Threading.Tasks.Parallel.ForEach(
    myEntities,
    new System.Threading.Tasks.ParallelOptions { MaxDegreeOfParallelism = maxThreads },
    entity =>
    {
        entity.Do()
    });

Второй вариант использовать Semaphore или SemaphoreSlim.

var myEntities = new MyEntity[100];
var maxThreads = 15;	

var semaphoreSlim = new SemaphoreSlim(maxThreads);
var tasks = new List<Task>(myEntities.Length);
foreach (var entity in myEntities)
{
	tasks.Add(Task.Run(() =>
	{
		semaphoreSlim.Wait();
		try
		{
			entity.Do();
		}
		finally
		{
			semaphoreSlim.Release();	
		}
	}));
}

Task.WaitAll(tasks.ToArray());

Если вы хотите использовать класс Thread напрямую, то

var myEntities = new MyEntity[100];
var maxThreads = 3;	

var semaphore = new Semaphore(maxThreads, maxThreads);
var threads = new List<Thread>(myEntities.Length);
foreach (var entity in myEntities)
{
	var thread = new Thread(() =>
	{
		semaphore.WaitOne();
		try
		{
			entity.Do();
		}
		finally
		{
			semaphore.Release();
		}
	});
	
	threads.Add(thread);
	
	thread.Start();
}

foreach (var thread in threads)
	thread.Join();

Хотя из условий задачи кажется, что здесь вполне можно обойтись Task. Task предпочтительней еще и по той причине, что потоки переиспользуются. Т.е. задействованных потоков будет столько, сколько одновременно выполняется задач, например 15. В случае же создания потока напрямую через класс Thread, 15 будут работать, остальные просто ждать, при этом все равно расходуя ресурсы.