Есть класс для обработки пула задач.
public class PoolManager
{
List<Func<Task<string>>> _listFunc { get; set; }
List<string> _listName { get; set; }
public bool Active { get; set; } = false;
public PoolManager()
{
_listFunc = new List<Func<Task<string>>>();
_listName = new List<string>();
}
public async Task<string> StartPool()
{
if (!Active)
{
Active = true;
while (Active)
{
if (_listFunc.Count != 0)
{
await Task.Run(async () =>
{
var fun = _listFunc[0];
RemoveById(0);
await fun();
});
}
}
}
return "";
}
public void Add(Func<Task<string>> func,string name)
{
_listFunc.Add(new Func<Task< string >> (func));
_listName.Add(name);
}
public void Stop()
{
Active = false;
}
}
Всё работает, но есть необходимость запускать несколько паралельных таких пулов. запускаю я его так:
if (!VP[0].Active)
{
await Task.Run(async () =>
{
await VP[0].StartPool();
});
}
else VP[0].Stop();
Но таким образом я могу запустить только 1 такой поток. Как можно реализовать одновременный запуск нескольких таких потоков с возможностью в последствии обращаться к ним? И соответственно без блокировки главного потока.