STA线程异常传播

Question

我有一个必须作为 STA 运行的函数，并且我想将其异常传播到调用线程。在这里：

public void ExceptionBePropagatedThroughHere()
{
  Thread thread = new Thread(TheSTAThread);
  thread.SetApartmentState(ApartmentState.STA);
  thread.Start();
  thread.Join();
}

public void MainFunction()
{
  try
  {
    ExceptionBePropagatedThroughHere();
  }
  catch(Exception e)
  {
     //will not hit here
  }
}

将 STA 属性放在“MainFunction”上不是一个选项。 我注意到如果我使用任务，尝试捕获任务连接会将异常传播到调用线程，但是我无法指定以 STA 方式运行任务。

问题是如何将作为 STA 运行的异常传播到上例中的“MainFunction”？

提前致谢。

Answer 1

我遵循了汉斯的建议，解决方案如下所示，不需要触发任何事件。

private Exception _exception;
public void ExceptionBePropagatedThroughHere()
{
  Thread thread = new Thread(TheSTAThread);Thread thread = new Thread(TheSTAThread);
  thread.SetApartmentState(ApartmentState.STA);
  thread.Start();
  thread.Join();
  if(_exception != null)
    throw new Exception("STA thread failed", _exception);
}

private void TheSTAThread()
{
  try
  {
    //do the stuff
  }
  catch (Exception ex)
  {
    _exception = ex;
  }
}
public void MainFunction()
{
  try
  {
    ExceptionBePropagatedThroughHere();
  }
  catch(Exception e)
  {
     //will not hit here
  }
}

Answer 2

在等待期间，您需要保持消息泵的启动和运行。 Thread.Join 不是您可以使用的选项，因为它会阻塞您的线程，直到另一个线程终止。
一个非常简单的消息泵是创建两个名为 StaThreadExited 和 StaThreadExceptionEvent 的事件。您可以对事件数组使用 WaitHandle.WaitAny。如果这是一个异常事件，您可以从共享变量中获取它，然后将其重新抛出到您自己的线程中。我什至前段时间在这里发布了 代码 。

你的，
阿洛伊斯·克劳斯

Answer 3

线程是 STA 还是 MTA 并不重要。其中未捕获的异常将使您的应用程序崩溃。您不能将其扔到创建行为不当线程的线程中，除非您设计一种手动执行此操作的方法：例如捕获、将其存储在某处并通知主线程出现错误

Answer 4

这是一个老问题，但我想我会尝试改进建议的解决方案。 C# 已经具有在线程之间传输异常和结果的便捷机制。它称为任务。如果您需要 STA 线程，则无法执行 Task.Run，但是使用这样的帮助程序，您可以使用 STA 线程获得同样的便利：

public class StaTask {
    public static Task Run(Action action) {
        var tcs = new TaskCompletionSource<object>();
        var thread = new Thread(() => {
            try {
                action();
                tcs.SetResult(null);
            }
            catch (Exception e)
            {
                tcs.SetException(e);
            }
        });
        thread.SetApartmentState(ApartmentState.STA);
        thread.Start();
        return tcs.Task;
    }
}

当然，可以通过添加混合通用返回类型。