Самый чистый способ вызвать межпотоковые события
-
09-06-2019 - |
Вопрос
Я обнаружил, что модель событий .NET такова, что мне часто приходится вызывать событие в одном потоке и прослушивать его в другом потоке.Мне было интересно, какой самый чистый способ маршалировать событие из фонового потока в мой поток пользовательского интерфейса.
Основываясь на предложениях сообщества, я использовал это:
// earlier in the code
mCoolObject.CoolEvent+=
new CoolObjectEventHandler(mCoolObject_CoolEvent);
// then
private void mCoolObject_CoolEvent(object sender, CoolObjectEventArgs args)
{
if (InvokeRequired)
{
CoolObjectEventHandler cb =
new CoolObjectEventHandler(
mCoolObject_CoolEvent);
Invoke(cb, new object[] { sender, args });
return;
}
// do the dirty work of my method here
}
Решение
Пара наблюдений:
- Не создавайте простые делегаты явно в таком коде, если только вы не используете версию 2.0, чтобы вы могли использовать:
BeginInvoke(new EventHandler<CoolObjectEventArgs>(mCoolObject_CoolEvent),
sender,
args);
Также вам не нужно создавать и заполнять массив объектов, поскольку параметр args является типом «params», поэтому вы можете просто передать его в список.
Я бы, наверное, отдал предпочтение
Invoke
надBeginInvoke
поскольку последнее приведет к асинхронному вызову кода, что может быть, а может и не быть тем, что вам нужно, но затруднит распространение последующих исключений без вызоваEndInvoke
.В результате ваше приложение получитTargetInvocationException
вместо.
Другие советы
У меня есть какой-то код для этого В сети.Это намного лучше, чем другие предложения;обязательно проверьте это.
Пример использования:
private void mCoolObject_CoolEvent(object sender, CoolObjectEventArgs args)
{
// You could use "() =>" in place of "delegate"; it's a style choice.
this.Invoke(delegate
{
// Do the dirty work of my method here.
});
}
Я избегаю избыточных объявлений делегатов.
private void mCoolObject_CoolEvent(object sender, CoolObjectEventArgs args)
{
if (InvokeRequired)
{
Invoke(new Action<object, CoolObjectEventArgs>(mCoolObject_CoolEvent), sender, args);
return;
}
// do the dirty work of my method here
}
Для несобытий вы можете использовать System.Windows.Forms.MethodInvoker
делегировать или System.Action
.
РЕДАКТИРОВАТЬ:Кроме того, каждое событие имеет соответствующее EventHandler
делегат, поэтому нет необходимости его переобъявлять.
Я создал следующий «универсальный» класс межпотоковых вызовов для своих целей, но думаю, стоит им поделиться:
using System;
using System.Collections.Generic;
using System.Text;
using System.Windows.Forms;
namespace CrossThreadCalls
{
public static class clsCrossThreadCalls
{
private delegate void SetAnyPropertyCallBack(Control c, string Property, object Value);
public static void SetAnyProperty(Control c, string Property, object Value)
{
if (c.GetType().GetProperty(Property) != null)
{
//The given property exists
if (c.InvokeRequired)
{
SetAnyPropertyCallBack d = new SetAnyPropertyCallBack(SetAnyProperty);
c.BeginInvoke(d, c, Property, Value);
}
else
{
c.GetType().GetProperty(Property).SetValue(c, Value, null);
}
}
}
private delegate void SetTextPropertyCallBack(Control c, string Value);
public static void SetTextProperty(Control c, string Value)
{
if (c.InvokeRequired)
{
SetTextPropertyCallBack d = new SetTextPropertyCallBack(SetTextProperty);
c.BeginInvoke(d, c, Value);
}
else
{
c.Text = Value;
}
}
}
И вы можете просто использовать SetAnyProperty() из другого потока:
CrossThreadCalls.clsCrossThreadCalls.SetAnyProperty(lb_Speed, "Text", KvaserCanReader.GetSpeed.ToString());
В этом примере приведенный выше класс KvaserCanReader запускает собственный поток и вызывает установку свойства text метки lb_Speed в главной форме.
Я думаю, что самый чистый способ определенно идти по маршруту АОП.Сделайте несколько аспектов, добавьте необходимые атрибуты, и вам больше никогда не придется проверять сходство потоков.
Используйте контекст синхронизации, если вы хотите отправить результат в поток пользовательского интерфейса.Мне нужно было изменить приоритет потока, поэтому я отказался от использования потоков пула потоков (закомментированный код) и создал собственный новый поток.Я все еще мог использовать контекст синхронизации, чтобы узнать, удалось ли отменить базу данных или нет.
#region SyncContextCancel
private SynchronizationContext _syncContextCancel;
/// <summary>
/// Gets the synchronization context used for UI-related operations.
/// </summary>
/// <value>The synchronization context.</value>
protected SynchronizationContext SyncContextCancel
{
get { return _syncContextCancel; }
}
#endregion //SyncContextCancel
public void CancelCurrentDbCommand()
{
_syncContextCancel = SynchronizationContext.Current;
//ThreadPool.QueueUserWorkItem(CancelWork, null);
Thread worker = new Thread(new ThreadStart(CancelWork));
worker.Priority = ThreadPriority.Highest;
worker.Start();
}
SQLiteConnection _connection;
private void CancelWork()//object state
{
bool success = false;
try
{
if (_connection != null)
{
log.Debug("call cancel");
_connection.Cancel();
log.Debug("cancel complete");
_connection.Close();
log.Debug("close complete");
success = true;
log.Debug("long running query cancelled" + DateTime.Now.ToLongTimeString());
}
}
catch (Exception ex)
{
log.Error(ex.Message, ex);
}
SyncContextCancel.Send(CancelCompleted, new object[] { success });
}
public void CancelCompleted(object state)
{
object[] args = (object[])state;
bool success = (bool)args[0];
if (success)
{
log.Debug("long running query cancelled" + DateTime.Now.ToLongTimeString());
}
}
Я всегда задавался вопросом, насколько это дорого всегда предположим, что требуется вызов...
private void OnCoolEvent(CoolObjectEventArgs e)
{
BeginInvoke((o,e) => /*do work here*/,this, e);
}
Интересно отметить, что привязка WPF автоматически обрабатывает маршалинг, поэтому вы можете привязать пользовательский интерфейс к свойствам объекта, которые изменяются в фоновых потоках, без необходимости делать что-либо специальное.Для меня это оказалось отличной экономией времени.
В XAML:
<TextBox Text="{Binding Path=Name}"/>
Вы можете попытаться разработать какой-то общий компонент, который принимает Контекст синхронизации в качестве входных данных и использует его для вызова событий.