// System Thread Distribution Processing
		private Queue __distQueue = new Queue();
		private AutoResetEvent __distEvent = new AutoResetEvent(false); 
		internal CWorkItem GetDistItem()
		{
			CWorkItem nextWi = null;
			do
			{
				lock(__distQueue.SyncRoot)
				{
					if (__distQueue.Count>0)
						nextWi = (CWorkItem)__distQueue.Dequeue();
				}
				if (nextWi==null)
				{
					if (CTrace.TraceOn) CTrace.Trace1("DistThread waiting for work", _
  "Distrib");
					__distEvent.WaitOne();
					if (CTrace.TraceOn) CTrace.Trace1("DistThread received work", "Distrib");
				}
			}
			while(nextWi==null&&!_app.CloseDown);
			if (_app.CloseDown)
			{
				if (CTrace.TraceOn) CTrace.Trace1("DistThread woken for system closedown", _
  "Distrib");
			}
			else
				if (CTrace.TraceOn) CTrace.Trace1("DistThread item obtained from queue", _
  "Distrib");
			return nextWi;
 
		} // GetDistItem()
 
		private void postDistItem(CWorkItem wi)
		{
			lock(__distQueue.SyncRoot)
			{
				if (CTrace.TraceOn) CTrace.Trace1("Posting work item for DistThread", _
  "Distrib");
				__distQueue.Enqueue(wi);
				if (__distQueue.Count>NWStats.MaxQueuedDistItems)
					NWStats.SetMaxQueuedDistItems(__distQueue.Count);
				if (__distQueue.Count==1)
				{
					if (CTrace.TraceOn) CTrace.Trace1("Waking up DistThread", "Distrib");
					// Post (maybe) waiting distribution thread
					__distEvent.Set();
				}
			}
		}  // postDistItem()

________
Alle Angaben ohne Gewähr. Keine Haftung für Vorschläge, Tipps oder sonstige Hilfe, falls es schiefgeht, nur Zeit verschwendet oder man sonst nicht zufrieden ist