Prism EventAggregator 可以用于满足线程需求吗？

Question

我正在查看 Prism EventAggregator，它非常棒。我最关心的是它正确地将线程编组到 UI 线程的能力。

我想知道是否可以使用此功能为模块开发人员提供一个类，该类可用于以与 BackgroundWorker 类似的方式创建线程。类的接口可以有点类似于

public interface IMyTask
{
    event DoWorkEventHandler DoWork;
    event RunWorkerCompletedEventHandler RunWorkerCompleted;
    void RunTaskAsync(object obj);
}

我保留了类似于backgroundworker的类型以便更好地理解。在实现中，我正在注册任务启动和任务完成事件

public class TaskStartEventPayload
{
    public SubscriptionToken token { get; set; }
    public object Argument { get; set; }
}

public class TaskStartEvent : CompositePresentationEvent<TaskStartEventPayload>
{
}

public class TaskCompleteEventPayload
{
    public SubscriptionToken token { get; set; }
    public object Argument { get; set; }
    public object Result { get; set; }
}
public class TaskCompleteEvent : CompositePresentationEvent<TaskCompleteEventPayload>
{
}

在 MyTask 类的构造函数中，我采用哪个线程需要完成，因为

 public MyTask(IEventAggregator eventAggregator, bool isUICompletion)
 {
       if (eventAggregator == null)
       {
                throw new ArgumentNullException("eventAggregator");
            }
            _eventAggregator = eventAggregator;
            _eventAggregator.GetEvent<TaskStartEvent>().Subscribe(TaskStartHandler, ThreadOption.BackgroundThread, false, new Predicate<TaskStartEventPayload>(StartTokenFilter));
            if(isUICompletion)
                _token = _eventAggregator.GetEvent<TaskCompleteEvent>().Subscribe(TaskCompleteHandler, ThreadOption.UIThread,true,new Predicate<TaskCompleteEventPayload>(CompleteTokenFilter));
            else
                _token = _eventAggregator.GetEvent<TaskCompleteEvent>().Subscribe(TaskCompleteHandler, ThreadOption.BackgroundThread, true, new Predicate<TaskCompleteEventPayload>(CompleteTokenFilter));
        }

这里我正在向过滤器注册，其中过滤器函数仅当 Payload 具有与 get while 相同的令牌时才返回事件订阅。

进一步我使用

 public void RunTaskAsync(object obj)
{
    //create payload
    _eventAggregator.GetEvent<TaskStartEvent>().Publish(payload);
}
public void TaskStartHandler(TaskStartEventPayload t)
{
     //fire dowork and create payload
     DoWork(this, args);
     _eventAggregator.GetEvent<TaskCompleteEvent>().Publish(tc);
}
public void TaskCompleteHandler(TaskCompleteEventPayload t)
{
    RunWorkerCompleted(this, args);
}

这个类可以用作

        MyTask et = new MyTaskagg, true);
        et.DoWork += new System.ComponentModel.DoWorkEventHandler(et_DoWork);
        et.RunWorkerCompleted += new System.ComponentModel.RunWorkerCompletedEventHandler(et_RunWorkerCompleted);            
        et.RunTaskAsync("Test");

我在这种方法中看到的好处是 1.它使用线程池，因此没有像backgroundWorker那样创建线程的开销。 2. 正确的线程编组，以防 RunWorkerCompleted 在 UI 线程上执行。

请告知使用 eventaggregator 作为 Threader 是否正确。

Answer 1

这是可行的，尽管您必须调试它的代码以获得很少的性能增益。在我看来，微观优化很少值得付出努力和支持成本。

EventAggregator 旨在成为应用程序的消息总线，我通常更喜欢按照其初衷使用事物，以免我必须调试大量代码，但这是我个人的偏好。

事件聚合器将不得不比原本要清理所有这些订阅更加努力，这可能会超过您从线程池获得的任何性能增益，但这只是一个猜测。