Структура FIFO с потоками ⇐ C#

Место общения программистов C#
Anonymous
Структура FIFO с потоками

Сообщение Anonymous »

Мне нужна помощь с моей проблемой, поэтому, если у кого-то была подобная проблема, я могу помочь. Спасибо.
Итак, я создал класс FifoScheduler. Находясь в Program.cs, я добавил две задачи в TaskScheduler, который на основе типа перечисления SchedulingAlghorithm распознает, какой планировщик задач я хочу запустить.
И теперь я тоже хочу быть возможность указать максимальное количество одновременных заданий, поэтому, если я укажу одно максимальное одновременное задание, я хочу, чтобы задания выполнялись одно за другим, причем каждое из них должно завершиться, чтобы начаться. Если у меня 2 максимально конкурентных задания, то параллельно нужно выполнять только два задания и т.д.
В чем у меня проблема, выполняется только одно задание, и программа завершается , я не понимаю как?
Вот мой код:
FifoScheduler.cs
public void Schedule(Job job)
{
job.OnJobPaused = HandlePause;

lock (_lock)
{
if (currentlyRunningJobCount < maxConcurrentJobs)
{
currentlyRunningJobCount++;
new Thread(() =>
{
job.Start();
lock (_lock)
{
currentlyRunningJobCount--;
if (jobQueue.TryDequeue(out Job? nextJob))
{
Schedule(nextJob);
}
}
}).Start();
}
else
{
jobQueue.Enqueue(job);
}
}
}

Program.cs
using MyTaskScheduler;
using MyTaskSchedulerLib;

var scheduler = new MyTaskSchedulerLib.TaskScheduler(maxConcurrentJobs:1);

Job job1 = new(new DemoUserJob(name: "job1"), scheduler);
Job job2 = new(new DemoUserJob(name: "job2"), scheduler);

scheduler.Schedule(job: job1, MyTaskSchedulerLib.TaskScheduler.SchedulerAlgorithm.FIFO);
scheduler.Schedule(job: job2, MyTaskSchedulerLib.TaskScheduler.SchedulerAlgorithm.FIFO);


Result:
Job job1 started.
job1: 0
job1: 1
job1: 2
job1: 3
job1: 4
job1: 5
job1: 6
job1: 7
job1: 8
job1: 9
Job job1 ended.
Program terminate


Подробнее здесь: https://stackoverflow.com/questions/791 ... th-threads

Вернуться в «C#»