其他分享
首页 > 其他分享> > 为什么Task.Delay中断线程的STA状态?

为什么Task.Delay中断线程的STA状态?

作者:互联网

介绍

这是一个冗长的问题!您将在开始时找到有关该问题的一些背景知识,然后是代码示例,这些示例已简化了表示形式,之后又简化了“问题”.请以任何适合您的顺序阅读!

背景资料

我正在为与STA COM通信的应用程序编写概念证明部分.应用程序的这一部分需要在单线程单元(STA)上下文中运行,以便与所述STA COM通信.该应用程序的其余部分在MTA上下文中运行.

当前状态

到目前为止,我想出的是创建一个包含在STA中运行的while循环的Communication类.需要中继到COM对象的工作通过ConcurrentQueue从外部排队到Communication类.然后,将工作项在while循环中出队并执行工作.

代码上下文

交流班

这是一个静态类,包含一个旨在在STA状态下运行的循环,并检查COM是否需要完成某些工作并将其分派到处理程序.

static class Communication
{
    #region Public Events

    /// This event is raised when the COM object has been initialized
    public static event EventHandler OnCOMInitialized;

    #endregion Public Events

    #region Private Members

    /// Stores a reference to the COM object
    private static COMType s_comObject;

    /// Used to queue work that needs to be done by the COM object
    private static ConcurrentQueue<WorkUnit> s_workQueue;

    #endregion Private Members

    #region Private Methods

    /// Initializes the COM object
    private static void InternalInitializeCOM()
    {
        s_comObject = new COMType();

        if (s_comObject.Init())
        {
            OnCOMInitialized?.Invoke(null, EventArgs.Empty);
        }
    }

    /// Dispatches the work unit to the correct handler
    private static void HandleWork(WorkUnit work)
    {
        switch (work.Command)
        {
            case WorkCommand.Initialize:
                InternalInitializeCOM();
                break;
            default:
                break;
        }
    }

    #endregion Private Methods

    #region Public Methods

    /// Starts the processing loop
    public static void StartCommunication()
    {
        s_workQueue = new ConcurrentQueue<WorkUnit>();

        while (true)
        {
            if (s_workQueue.TryDequeue(out var workUnit))
            {
                HandleWork(workUnit);
            }

            // [Place for a delaying logic]
        }
    }

    /// Wraps the work unit creation for the task of Initializing the COM
    public static void InitializeCOM()
    {
        var workUnit = new WorkUnit(
            command: WorkCommand.Initialize,
            arguments: null
        );
        s_workQueue.Enqueue(workUnit);
    }

    #endregion Public Methods
}

工作指令

此类描述了需要完成的工作以及可能提供的任何参数.

enum WorkCommand
{
    Initialize
}

工作单位

该枚举定义了COM可以执行的各种任务.

class WorkUnit
{
    #region Public Properties

    public WorkCommand Command { get; private set; }

    public object[] Arguments { get; private set; }

    #endregion Public Properties

    #region Constructor

    public WorkUnit(WorkCommand command, object[] arguments)
    {
        Command = command;
        Arguments = arguments == null
            ? new object[0]
            : arguments;
    }

    #endregion Constructor
}

所有者

这是拥有或产生与COM的通信的类的示例,并且是通信的抽象,供在应用程序的其余部分中使用.

class COMController
{
    #region Public Events

    /// This event is raised when the COM object has been initialized
    public event EventHandler OnInitialize;

    #endregion Public Events

    #region Constructor

    /// Creates a new COMController instance and starts the communication
    public COMController()
    {
        var communicationThread = new Thread(() =>
        {
            Communication.StartCommunication();
        });
        communicationThread.SetApartmentState(ApartmentState.STA);
        communicationThread.Start();

        Communication.OnCOMInitialized += HandleCOMInitialized;
    }

    #endregion Constructor

    #region Private Methods

    /// Handles the initialized event raised from the Communication
    private void HandleCOMInitialized()
    {
        OnInitialize?.Invoke(this, EventArgs.Emtpy);
    }

    #endregion Private Methods

    #region Public Methods

    /// Requests that the COM object be initialized
    public void Initialize()
    {
        Communication.InitializeCOM();
    }

    #endregion Public Methods
}

问题

现在,看看Communication.StartCommunication()方法,更具体地讲这部分:

...
// [Place for a delaying logic]
...

如果用以下内容替换此行:

await Task.Delay(TimeSpan.FromMilliseconds(100)).ConfigureAwait(false);
// OR
await Task.Delay(TimeSpan.FromMilliseconds(100)).ConfigureAwait(true);

在检查过程中的最后一站-Communication.InternalInitializeCOM()线程所在的单元似乎是MTA.

但是,如果将延迟逻辑更改为

Thread.Sleep(100);

CommunicationInternalInitializeCOM()方法似乎在STA状态下执行.

该检查由Thread.CurrentThread.GetApartmentState()完成.

问题

谁能告诉我为什么Task.Delay破坏STA状态?还是我在做其他错误的事情?

谢谢!

感谢您抽出宝贵的时间阅读问题!祝你有美好的一天!

解决方法:

汉斯钉牢了它.从技术上讲,您的代码正在中断,因为没有SynchronizationContextcaptured by the await.但是,即使您编写了一个,也还不够.

这种方法的一个大问题是您的STA线程未启动. STA线程必须泵送Win32消息队列,否则它们不是STA线程. SetApartmentState(ApartmentState.STA)只是告诉运行时这是一个STA线程.它不会使其成为STA线程.您必须泵送消息,使其成为STA线程.

您可以自己编写该消息泵,尽管我不知道有人敢于这样做.大多数人都从WinForms (a la Hans’ answer)WPF安装消息泵.也可以从UWP message pump安装消息泵.

使用提供的消息泵的一个很好的副作用是它们还提供了SynchronizationContext(例如WinFormsSynchronizationContext / DispatcherSynchronizationContext),因此await可以自然地工作.另外,由于每个.NET UI框架都定义了一个“运行此委托” Win32消息,因此基础Win32消息队列也可以包含您要排队到线程的所有工作,因此不再需要显式队列及其“运行程序”代码必要.

标签:multithreading,com,sta,mta,c
来源: https://codeday.me/bug/20191108/2005685.html