【转】 .NET中STAThread和MTAThread

摘要:
裁判:http://blog.csdn.net/dyllove98/article/details/97359551COM本文讨论进程内COM组件。使用一个示例直观地演示STAThread和MTAThread之间的功能和差异。1.1基本规则公寓是COM组件的操作环境。日常生活中的公寓是用来住人的。COM中的公寓用于COM组件的活动对象。每个COM对象必须且只能位于一个单元中:单线程单元(STA)

ref:http://blog.csdn.net/dyllove98/article/details/9735955

1 COM中的公寓

本文讨论进程内COM组件。以一个示例直观演示STAThread和MTAThread的作用和区别。

1.1 基本规则

公寓是COM组件的运行环境,日常生活中公寓是用来住人的,COM中的公寓是用来住COM组件的对象的,每个COM对象必须且只能位于一个公寓中:单线程公寓(STA)或多线程公寓(MTA)。

每个进程可以有0或多个STA。

每个进程可以有0或1个MTA。

一个线程只能关联到一个公寓。因此所有关联到MTA的线程都是关联到进程唯一的一个MTA。

本线程访问与本线程关联的STA中的COM对象不需要列集,直接访问。

其他线程对STA中的COM对象的访问需要列集(marshal),通过列集,自动实现了多线程访问下的同步

所有线程对MTA中的COM对象的访问不需要列集,直接访问,需要COM组件自身实现多线程下的同步

(列集就是将函数调用序列化,实现跨边界调用,在Windows中通常是通过消息机制实现。在COM中RPC就是列集,在WinForm中Control.Invoke就是一种列集,Remoting也是列集,WCF也是列集,最近流行的RESTfull也是。。。)

1.2 公寓类型匹配

一个COM对象所属的公寓,由两个地方的配置确定:组件公寓模型客户端线程公寓模型

  1. 组件公寓模型是在组件注册到注册表时设定,通过组件公寓模型,组件声明自己可以住在什么样的公寓里。可选项包括:Apartment,Free和Both。Apartment,我只能住在单线程公寓中;Free,我只能住在多线程公寓中;Both,我随意,单线程公寓或多线程公寓都可以。
  2. 客户端线程公寓模型就是线程的公寓模型,表示当前线程提供什么样的公寓。可选项包括:单线程公寓(STA)或多线程公寓(MTA),也就是本文所讨论的STAThread和MTAThread。

下表列出了组件对象最终会住在什么公寓中的组合表:

客户端线程公寓模型 组件公寓模型 ApartmentFreeBoth
STASTAMTASTA
MTASTAMTAMTA

如果组件公寓模型为Apartment,不管客户端线程公寓模型是什么,组件最后都住在STA中,因为组件说了“我只能住在单线程公寓中”。如果当前线程是MTA,COM库会后台创建一个STA来放该组件的对象。

如果组件公寓模型为Free,不管客户端线程公寓模型是什么,组件最后都住在MTA中,因为组件说了“我只能住在多线程公寓中”。如果当前线程是STA,COM库会检查当前进程的MTA有没有创建,没有就创建进程的MTA,然后将组件的对象放在MTA中。

如果组件公寓模型为Both,组件最后都住在与当前线程关联的公寓中,如果当前线程是STA,它就住在STA中;当前线程是MTA,它就住在MTA中。本文中,我们会创建一个并注册一个Both类型的组件,然后分别在STA和MTA中创建该组件的对象。

1.3 .NET中设置客户端线程公寓模型 

在.NET中使用COM组件时,需要设置线程的公寓模型。 

在.NET中可以通过STAThread和MTAThread属性来设置主线程的公寓类型, 通过Thread.SetApartmentState可以设置工作线程的公寓类型。

对于WinForm或WPF应用程序,主线程的公寓模型必须为STA,因为用户界面对象都不是线程安全的。

对于控制台应用程序,主线程的公寓模型可以随意设置,为了方便,我们用控制台应用程序来演示。(用WinForm也完全可以演示,只是需要在工作线程中创建组件的对象。)

2 一个简单的COM组件

为了演示单线程公寓和多线程公寓的区别,我们用ATL实现定义一个简单的COM组件SimpleCom,该组件包含一个返回字符串的方法Hello,返回的字符串分三步合成,每步之间通过Consume方法来消耗较长CPU周期,确保Hello不会在操作系统的一个时间片内被执行完成,保证Hello函数被并发执行,以达到演示的效果。代码如下:

 1 // CSimpleCom.h
 2 class ATL_NO_VTABLE CSimpleCom :
 3     public CComObjectRootEx<CComSingleThreadModel>,
 4     public CComCoClass<CSimpleCom, &CLSID_SimpleCom>,
 5     public IConnectionPointContainerImpl<CSimpleCom>,
 6     public CProxy_ISimpleComEvents<CSimpleCom>,
 7     public IDispatchImpl<ISimpleCom, &IID_ISimpleCom, &LIBID_ATLTestLib, /*wMajor =*/ 1, /*wMinor =*/ 0>
 8 {
 9 public:
10     CSimpleCom()
11     {
12         this->m_iMember = 0;
13     }
14 
15 DECLARE_REGISTRY_RESOURCEID(IDR_SIMPLECOM)
16 
17 
18 BEGIN_COM_MAP(CSimpleCom)
19     COM_INTERFACE_ENTRY(ISimpleCom)
20     COM_INTERFACE_ENTRY(IDispatch)
21     COM_INTERFACE_ENTRY(IConnectionPointContainer)
22 END_COM_MAP()
23 
24 BEGIN_CONNECTION_POINT_MAP(CSimpleCom)
25     CONNECTION_POINT_ENTRY(__uuidof(_ISimpleComEvents))
26 END_CONNECTION_POINT_MAP()
27 
28 
29     DECLARE_PROTECT_FINAL_CONSTRUCT()
30 
31     HRESULT FinalConstruct()
32     {
33         return S_OK;
34     }
35 
36     void FinalRelease()
37     {
38     }
39 
40 public:
41     STDMETHOD(Hello)(BSTR* a);
42 private:
43     int m_iMember;
44     CString m_str;
45 };
46 
47 OBJECT_ENTRY_AUTO(__uuidof(SimpleCom), CSimpleCom)
 1 // CSimpleCom.cpp
 2 double Cosume()
 3 {
 4     double d = 0;
 5     for (int i = 0; i < 1000*1000*300; i++)
 6     {
 7         d += i;
 8     }
 9     return d;
10 }
11 
12 STDMETHODIMP CSimpleCom::Hello(BSTR* a)
13 {
14     m_str = L"0>你好! ";
15     Cosume();
16     CString str;
17     str.Format(L"1>m_iMember = %d; " , this->m_iMember++);
18     m_str += str;
19     Cosume();
20     m_str += L"2>再见~";
21     *a = m_str.AllocSysString();
22     return S_OK;
23 }

将组件的ThreadingModel设置为Both,生成项目,组件会自动注册。

接下来创建C#客户端,使用该组件。

3 C#客户端

新建一个C#控制台应用程序,添加对SimpleCom组件的引用,在主线程中创建SimpleCom组件的对象,在两个工作线程中同时调用该对象。

通过修改主线程的公寓类型,演示进程内COM组件对象在不同类型的公寓中的行为差异。

3.1 多线程公寓

在多线程公寓中创建SimpleCom组件的对象的代码如下:

 1 namespace ConsoleApplication1
 2 {
 3     class Program
 4     {
 5         [MTAThread()]
 6         static void Main(string[] args)
 7         {
 8             var v = new ATLTestLib.SimpleCom();
 9             Thread t = new Thread(x =>
10             {
11                 Run((ATLTestLib.ISimpleCom)x);
12             });
13             t.SetApartmentState(ApartmentState.STA);
14             t.Start(v);
15             Thread.Sleep(300);
16             Thread t2 = new Thread(x =>
17             {
18                 Run((ATLTestLib.ISimpleCom)x);
19             });
20             t2.SetApartmentState(ApartmentState.STA);
21             t2.Start(v);
22         }
23 
24         static public void Run(ATLTestLib.ISimpleCom sc)
25         {
26             try
27             {
28                 for (var i = 0; i < 5; i++)
29                 {
30                     Console.WriteLine(string.Format("[{0}] {1}",
31                         Thread.CurrentThread.ManagedThreadId,
32                         sc.Hello()));
33                 }
34             }
35             catch (Exception ex)
36             {
37                 Console.WriteLine(ex);
38             }
39         }
40     }
41 }

运行结果如下:

[3] 0>你好! 1>m_iMember = 0; 1>m_iMember = 1; 2>再见~
[5] 0>你好! 2>再见~
[3] 0>你好! 1>m_iMember = 2; 1>m_iMember = 3; 2>再见~
[5] 0>你好! 2>再见~
[3] 0>你好! 1>m_iMember = 4; 1>m_iMember = 5; 2>再见~
[5] 0>你好! 2>再见~
[3] 0>你好! 1>m_iMember = 6; 1>m_iMember = 7; 2>再见~
[5] 0>你好! 2>再见~
[3] 0>你好! 1>m_iMember = 8; 1>m_iMember = 9; 2>再见~
[5] 0>你好! 1>m_iMember = 8; 1>m_iMember = 9; 2>再见~2>再见~
请按任意键继续. . .

原理说明:

由于两个线程的代码能够同时调用组件对象v的方法,组件中m_str的值被两个线程同时修改,Hello方法返回的值出现了混乱,典型的缺乏的同步的结果。

3.2 单线程公寓

单线程公寓只需要将上面代码中的MTAThread改为STAThread即可。

输出如下:

[3] 0>你好! 1>m_iMember = 0; 2>再见~
[4] 0>你好! 1>m_iMember = 1; 2>再见~
[3] 0>你好! 1>m_iMember = 2; 2>再见~
[4] 0>你好! 1>m_iMember = 3; 2>再见~
[3] 0>你好! 1>m_iMember = 4; 2>再见~
[4] 0>你好! 1>m_iMember = 5; 2>再见~
[3] 0>你好! 1>m_iMember = 6; 2>再见~
[4] 0>你好! 1>m_iMember = 7; 2>再见~
[3] 0>你好! 1>m_iMember = 8; 2>再见~
[4] 0>你好! 1>m_iMember = 9; 2>再见~
请按任意键继续. . .

原理说明:

由于对STA中对象的调用都被COM运行时列集,自动对多线程调用实现了同步。 

免责声明:文章转载自《【转】 .NET中STAThread和MTAThread》仅用于学习参考。如对内容有疑问,请及时联系本站处理。

上篇简单的着色问题nginx 设置 404 500 页面跳转到指定页面下篇

宿迁高防,2C2G15M,22元/月;香港BGP,2C5G5M,25元/月 雨云优惠码:MjYwNzM=

相关文章

CPU上下文切换分析

一、CPU上下文切换 1、上下文切换,有时也称做进程切换或任务切换,是指CPU从一个进程或线程切换到另一个进程或线程。 2、vmstat是一个常用的系统性能分析工具,主要用来分析系统内存使用情况,也常用来分析CPU上下文切换和中断的次数。 例:vmstat -w 上下文切换需要特别关注的四列内容: cs(context switch)  是每秒上下文切换...

java中终止线程的三种方式

在java中有三种方式可以终止线程。分别为:   1.  使用退出标志,使线程正常退出,也就是当run方法完成后线程终止。      2.  使用stop方法强行终止线程(这个方法不推荐使用,因为stop和suspend、resume一样,也可能发生不可预料的结果)。        3.  使用interrupt方法中断线程。 下面我们来详细的介绍这三种方...

JavaNetty拆包粘包(二)

netty 使用 tcp/ip 协议传输数据。而 tcp/ip 协议是类似水流一样的数据传输方式。多次 访问的时候有可能出现数据粘包的问题,解决这种问题的方式如下: 定长数据流  客户端和服务器,提前协调好,每个消息长度固定。(如:长度 10)。如果客户端或服 务器写出的数据不足 10,则使用空白字符补足(如:使用空格)。  /** * 1. 单线程组...

WinForm 进程、线程

一、进程 进程是一个具有独立功能的程序关于某个数据集合的一次运行活动。 它可以申请和拥有系统资源,是一个动态的概念,是一个活动的实体。 Process 类,用来操作进程。 命名空间:using System.Diagnostics; Process.Start("calc");   //打开计算器Process.Start("mspaint");   /...

死锁检测

曾经参与过的一款网络游戏,其服务器使用了异常复杂的多线程序解决方案。导致应用层程序员编写的代码很容易就出现死锁。 最终,公司的一个老员工,只能开发了一个死锁检测框架,在debug模式下运行时,只要发生死锁就会打印出调用堆栈。 虽然说这个框架基本可以在上线前把所有的死锁都检测了出来,但是,规根到底这是设计不合理造成的,多线程利用好了会提升 应用的效率,用不好...

InvokeRequired与Invoke

在多线程应用中将会涉及不同的线程访问同一控件的问题,C#中禁止跨线程直接访问控件。某个控件在被创建时就记下了是谁创建了它,即它的创建线程。如果从另一个线程调用该控件,那么必须使用控件的 Invoke 方法来将调用封送现在调用它的线程。(Invoke方法是控件的方法) 到底是哪个线程要使用该控件呢?需要用InvokeRequired来询问一下,如果当前调用线...