Mercurial > pub > ImplabNet

comparison Implab.Diagnostics.Interactive/InteractiveListener.cs @ 85:abe260860bd6 v2

Find changesets by keywords (author, files, the commit message), revision number or hash, or revset expression.
fixed JSONXmlReader disposing under ugly mono ObjectPool is made abstract
author cin
date Tue, 30 Sep 2014 16:05:35 +0400
parents 790e8a997d30
children 4c0e5ef99986
comparison
equal deleted inserted replaced
84:34bb2f32634d 85:abe260860bd6
15 15
16 SynchronizationContext m_syncGuiThread; 16 SynchronizationContext m_syncGuiThread;
17 readonly Promise<object> m_guiStarted = new Promise<object>(); 17 readonly Promise<object> m_guiStarted = new Promise<object>();
18 18
19 readonly IPromise m_guiFinished; 19 readonly IPromise m_guiFinished;
20 readonly IPromise m_workerFinished = new Promise<object>(); 20 // readonly IPromise m_workerFinished = new Promise<object>();
21 21
22 readonly MTQueue<TraceViewItem> m_queue = new MTQueue<TraceViewItem>(); 22 readonly MTQueue<TraceViewItem> m_queue = new MTQueue<TraceViewItem>();
23 readonly AutoResetEvent m_queueEvent = new AutoResetEvent(false); 23 readonly AutoResetEvent m_queueEvent = new AutoResetEvent(false);
24 24
25 int m_queueLength; 25 int m_queueLength;
29 bool m_paused; 29 bool m_paused;
30 readonly ManualResetEvent m_pauseEvent = new ManualResetEvent(true); 30 readonly ManualResetEvent m_pauseEvent = new ManualResetEvent(true);
31 31
32 public InteractiveListener(bool global) : base(global) { 32 public InteractiveListener(bool global) : base(global) {
33 m_guiFinished = AsyncPool.InvokeNewThread(GuiThread); 33 m_guiFinished = AsyncPool.InvokeNewThread(GuiThread);
34 m_workerFinished = AsyncPool.InvokeNewThread(QueueThread); 34 /*m_workerFinished = */AsyncPool.InvokeNewThread(QueueThread);
35 35
36 m_guiStarted.Join(); 36 m_guiStarted.Join();
37 } 37 }
38 38
39 void GuiThread() { 39 void GuiThread() {