(!Monitor.Wait(_syncRoot, 1000))wollte ich nun die Meldung ausgeben, wenn nach 1 sec der WorkerThread nicht beendet ist. Für mein verständniss müsste ich nach dem Timeout ein false zurück erhalten. Es scheint aber so, dass Wait dennoch bis zum Pulse des Worker Threads Blockiert und dann immer "false" zurückliefert.
static void Main(string[] args)
{
Thread notifyThread = new Thread(NotificationThread);
Thread workThread = new Thread(WorkerThread);
notifyThread.Start();
workThread.Start();
workThread.Join();
}
private static void WorkerThread()
{
Thread.Sleep(15);
lock (_syncRoot)
{
//Work Starts
for (int i = 0; i < 5; i++)
{
Console.WriteLine(i);
Thread.Sleep(1000);
}
// Work Finished
Console.WriteLine("Pulse");
Monitor.PulseAll(_syncRoot);
}
}
private static void NotificationThread()
{
lock(_syncRoot)
{
Console.WriteLine("Init Wait");
Thread.Sleep(1000);
Console.WriteLine("Start Wait");
Monitor.PulseAll(_syncRoot);
while (!Monitor.Wait(_syncRoot, 1000))
{
Console.WriteLine("Still Waiting for work");
Monitor.PulseAll(_syncRoot);
}
Console.WriteLine("Finished Waiting");
}
Console.WriteLine("Finished Process");
}
|
|
|
class Program
{
static void Main(string[] args)
{
Program p = new Program();
p.Example();
}
Semaphore workerResource = new Semaphore(1, 1); // single resource
AutoResetEvent workerFinished = new AutoResetEvent(false);
void Example()
{
Thread worker = new Thread(WorkerThreadFunc);
Thread monitor = new Thread(MonitoringThreadFunc);
worker.Start();
monitor.Start();
worker.Join();
monitor.Join();
workerResource.Close();
workerFinished.Close();
}
void WorkerThreadFunc()
{
Thread.Sleep(TimeSpan.FromMilliseconds(15));
workerResource.WaitOne();
//Work Starts
for (int i = 0; i < 5; i++)
{
Console.WriteLine(i);
Thread.Sleep(TimeSpan.FromMilliseconds(1000));
}
// Work Finished
Console.WriteLine("Worker finished (in worker thread)");
workerResource.Release();
workerFinished.Set();
}
void MonitoringThreadFunc()
{
while (!workerFinished.WaitOne(TimeSpan.FromMilliseconds(1000)))
{
Console.WriteLine("Still waiting for worker to finish...");
}
Console.WriteLine("Worker finished (in monitoring thread)");
}
}
|
|
|
