Синхронизация событий, основанных на одном объекте com

Question

Я использую API, который изначально был написан с помощью собственного кода и завершен с помощью .net-операций. API работает asynchronic, когда каждая операция вызывает событие, когда оно завершено. Вся моя логика синхронизирована, поэтому я хочу синхронизировать операции. Я делаю это с EventWaitHandle. вот код

Stock stock; 

private System.Threading.EventWaitHandle _signal = null; 

public void Sync() 

{ 

     _signal = new System.Threading.EventWaitHandle(false,  
         System.Threading.EventResetMode.AutoReset); 
     MBTradingProvider.Instance.FinnishGetStoch += new 
         EventHandler(Instance_FinnishGetStoch); 
     MBTradingProvider.Instance.GetStockAsync("IBM"); 
     _signal.WaitOne(); 
} 

void Instance_FinnishGetStoch(object sender, EventArgs e) 

{ 

     stock = MBTradingProvider.Instance.CurrentWorkongStock; 
     if (_signal != null) 
      _signal.Set();   
} 

Этот код застрял в строке _signal.WaitOne(), текущий поток замерзает и ничего не будет случилось. Я работал с одним и тем же шаблоном на другой асинхронной операции, и я отлично работаю. Единственное отличие, о котором я могу думать, это то, что под капотом работают объекты com, поскольку я сказал, что эффект, который я получаю, состоит в том, что код не отвечает после строки WaitOne

У кого-нибудь есть идея, что может быть неправильным?

Answer 1

Одной из проблем с этим кодом является назначение переменной _signal. Эта переменная атомизирована, но она не обязательно видна между всеми задействованными нитями. Вам необходимо использовать метод Interlocked.Exchange, чтобы гарантировать, что набор отображается одновременно во всех потоках.

System.Threading.EventWaitHandle temp = new System.Threading.EventWaitHandle(false,  
         System.Threading.EventResetMode.AutoReset); 
Interolocked.Exchange(ref _signal, temp); 

Кроме того, почему вы не используете событие AutoReset напрямую?

Answer 2

Ваш код кажется мне в порядке.

Я предполагаю следующее:

1. синхронизации() выполняется в ThreadA
2. Вызов GetStockAsync() создаст ThreadB, который будет выполнять какую-то задачу, чтобы получить акции информацию
3. По окончании получить акции Информация, ThreadB, не ThreadA, выполнит обработчик события, Instance_FinnishGetStoch(),

Моей грубая догадка что предположение №3 может быть неверным для вашей асинхронной структуры.

Возможно, вы захотите попробовать асинхронно и проверьте, какой поток выполняет GetStockAsyc(), и какой поток выполняет обработчик события Instance_FinishGetStock().

Если только один поток выполняет как GetStockAsync(), так и Instance_FinishGetStock(), ваш код, указанный выше, будет зависеть от _signal.WaitOne().

Например, в winform, если в потоке пользовательского интерфейса вызывается Form.BeginInoke (MyDelegate), MyDelegate будет выполняться в одном и том же потоке пользовательского интерфейса, но все же асинхронно.