1

Есть объект у закрытой библиотеке, на событие которого я подписываюсь, но оно возникает в основном потоке. И поэтому я не могу использовать AutoResetEvent, потому что в одном и том же потоке всё работает. А как можно реализовать так, чтобы событие возникало в новом потоке?

listenerPrice.Handler += new Listener.MessageHandler(MessageHandlerClientPrice);

1 ответ 1

3

Обработчик будет вызван в том потоке, где его вызывает отправитель события — в вашем случае, в главном потоке. Это обойти невозможно.

Вы можете, однако, получив событие, перебросить обработку в другой поток. Например, через Task.Run.


Для вашего случая:

// начало
// инициировать действие
// дождаться event'а
// конец

нужно переписать код в таком виде:

Listener.MessageHandler h = null;
h = (args) =>
{
    listenerPrice.Handler -= h;
    // конец
};
// начало
listenerPrice.Handler += h;
// инициировать действие

Ещё более хороший вариант — перейти на async/await. При этом ваш код будет таким:

// начало
// инициировать действие
await CallbackReceived();
// конец

Метод CallbackReceived можно имплементировать, например, как описано здесь: В чем смысл TaskCompletionSource<T> и когда его лучше использовать?

18
  • Хм... а разве события обрабатываются не в отдельном потоке по очереди?
    – iluxa1810
    Commented 12 февр. 2018 в 12:22
  • 2
    @iluxa1810: Нет. События обрабатываются синхронно в вызывающем потоке.
    – VladD
    Commented 12 февр. 2018 в 12:23
  • @VladD Вот я тоже думал, что во внешнем потоке. Попробую сейчас Ваш вариант, отпишусь после
    – Fresto
    Commented 12 февр. 2018 в 12:38
  • @VladD так, я прочитал, в самом колбэке вы хотите, чтобы реализация через другой поток была. Но мне нужно, чтобы при использовании AutoResetEvent основной поток остановился и ждал, а параллельно второй поток отследил событие и после его обработки основной поток продолжил. Поэтому даже вызов должен быть во внешнем потоке. А что тогда, если создать поток параллельно и в нем подписаться на ВСЕ мои события, а их штук 8. И он будет висеть до окончания программы. Тем самым параллельно вызываться. Это нормальное решение?
    – Fresto
    Commented 12 февр. 2018 в 12:52
  • @Fresto: «мне нужно, чтобы при использовании AutoResetEvent основной поток остановился и ждал» — а вот этого не понял. Откуда вдруг взялся AutoResetEvent? Что именно с чем вы хотите синхронизировать?
    – VladD
    Commented 12 февр. 2018 в 12:58

Ваш ответ

Нажимая «Отправить ответ», вы соглашаетесь с условиями пользования и подтверждаете, что прочитали политику конфиденциальности.

Всё ещё ищете ответ? Посмотрите другие вопросы с метками или задайте свой вопрос.