| Цитата | | На счет последнего вопроса: если кто, то раньше своей очереди подошел, то тот все равно должен ждать, когда перед ним все пройдут. |
Значит моё предположение было верным: ты хочешь, чтобы в какой-то момент потоки подождали друг друга и выполнились в определённом порядке.
Придумал я решение и не очень-то сложное, как оказалось Хотя может можно было и проще 
Прикрепил к этому сообщению. Писал в Visual Studio 2010, но там только в одном месте используется LinQ, а так в целом и под .NET 2.0 можно запустить заменив эту строчку.
На словах идея такая: для того, чтобы потоки выполняли какой-то код по очереди можно использовать Mutex (можно и что-то другое, но у Mutex есть несколько полезных свойств).
Проблема в том, что Mutex просто разрешает выполняться первому пришедшему потоку, а нам нужен определённый порядок. Поэтому прежде чем использовать Mutex надо проверить, а действительно ли текущий поток -- самый приоритетный. Если нет, то поток ставится на паузу и ожидает каких-либо изменений в очереди.
Написано в достаточно общем виде с учётом возможности непредвиденного завершения потоков или случая больше двух потоков.
Вот основной код, без комментариев, если вдруг кому-то интересно, а качать архив не хочется
| Код |
private readonly Dictionary<Thread, int> threadQ;
private readonly Mutex mutex;
public ThreadQueue()
{
threadQ = new Dictionary<Thread, int>();
mutex = new Mutex(false);
}
public void AddToQueue(int priority)
{
lock (threadQ)
{
threadQ.Add(Thread.CurrentThread, priority);
Monitor.PulseAll(threadQ);
}
}
public void RemoveFromQueue()
{
lock (threadQ)
{
threadQ.Remove(Thread.CurrentThread);
Monitor.PulseAll(threadQ);
}
}
public void Wait()
{
while (true)
{
int current;
int best;
lock (threadQ)
{
if (!threadQ.ContainsKey(Thread.CurrentThread))
throw new InvalidOperationException("Потока нет в очереди.");
current = threadQ[Thread.CurrentThread];
best = (from kvp in threadQ where kvp.Key.IsAlive select kvp.Value).Min();
}
if (current <= best)
{
try { mutex.WaitOne(); }
catch (AbandonedMutexException) { }
RemoveFromQueue();
break;
}
else
{
lock (threadQ)
{
Monitor.Wait(threadQ, 1000);
}
}
}
}
public void Continue()
{
try
{
mutex.ReleaseMutex();
}
catch(ApplicationException)
{
throw new InvalidOperationException("Continue можно вызывать только после Wait");
}
}
|
|
)