.NET中STAThread的使用详解
更新时间：2013年05月04日 11:40:11 作者：
这个STA线程模型，在线程内加入了讯息帮浦等等机制，减少开发人员撰写窗口程序的工作量
在WindowForm应用程序中主要的线程，是采用一种称为「Single-Threaded Apartment(STA)」的线程模型。这个STA线程模型，在线程内加入了讯息帮浦等等机制，减少开发人员撰写窗口程序的工作量。
而在开发类别库的时候，如果要使用类似的STA线程模型，可以使用下列的程序代码提供的类别来完成。
复制代码 代码如下:
namespace CLK.Threading
{
public class STAThread
{
// Enum
private enum ThreadState
{
Started,
Stopping,
Stopped,
}
// Fields
private readonly object _syncRoot = new object();
private readonly BlockingQueue<Action> _actionQueue = null;
private Thread _thread = null;
private ManualResetEvent _threadEvent = null;
private ThreadState _threadState = ThreadState.Stopped;
// Constructor
public STAThread()
{
// ActionQueue
_actionQueue = new BlockingQueue<Action>();
// ThreadEvent
_threadEvent = new ManualResetEvent(true);
// ThreadState
_threadState = ThreadState.Stopped;
}
// Methods
public void Start()
{
// Sync
lock (_syncRoot)
{
// ThreadState
if (_threadState != ThreadState.Stopped) throw new InvalidOperationException();
_threadState = ThreadState.Started;
}
// Thread
_thread = new Thread(this.Operate);
_thread.Name = string.Format("Class:{0}, Id:{1}", "STAThread", _thread.ManagedThreadId);
_thread.IsBackground = false;
_thread.Start();
}
public void Stop()
{
// Sync
lock (_syncRoot)
{
// ThreadState
if (_threadState != ThreadState.Started) throw new InvalidOperationException();
_threadState = ThreadState.Stopping;
// ActionQueue
_actionQueue.Release();
}
// Wait
_threadEvent.WaitOne();
}
public void Post(SendOrPostCallback callback, object state)
{
#region Contracts
if (callback == null) throw new ArgumentNullException();
#endregion
// Action
Action action = delegate()
{
try
{
callback(state);
}
catch (Exception ex)
{
Debug.Fail(string.Format("Delegate:{0}, State:{1}, Message:{2}", callback.GetType(), "Exception", ex.Message));
}
};
// Sync
lock (_syncRoot)
{
// ThreadState
if (_threadState != ThreadState.Started) throw new InvalidOperationException();
// ActionQueue
_actionQueue.Enqueue(action);
}
}
public void Send(SendOrPostCallback callback, object state)
{
#region Contracts
if (callback == null) throw new ArgumentNullException();
#endregion
// Action
ManualResetEvent actionEvent = new ManualResetEvent(false);
Action action = delegate()
{
try
{
callback(state);
}
catch (Exception ex)
{
Debug.Fail(string.Format("Delegate:{0}, State:{1}, Message:{2}", callback.GetType(), "Exception", ex.Message));
}
finally
{
actionEvent.Set();
}
};
// Sync
lock (_syncRoot)
{
// ThreadState
if (_threadState != ThreadState.Started) throw new InvalidOperationException();
// ActionQueue
if (Thread.CurrentThread != _thread)
{
_actionQueue.Enqueue(action);
}
}
// Execute
if (Thread.CurrentThread == _thread)
{
action();
}
// Wait
actionEvent.WaitOne();
}
private void Operate()
{
try
{
// Begin
_threadEvent.Reset();
// Operate
while (true)
{
// Action
Action action = _actionQueue.Dequeue();
// Execute
if (action != null)
{
action();
}
// ThreadState
if (action == null)
{
lock (_syncRoot)
{
if (_threadState == ThreadState.Stopping)
{
return;
}
}
}
}
}
finally
{
// End
lock (_syncRoot)
{
_threadState = ThreadState.Stopped;
}
_threadEvent.Set();
}
}
}
}
复制代码 代码如下:
namespace CLK.Threading
{
public class BlockingQueue<T>
{
// Fields
private readonly object _syncRoot = new object();
private readonly WaitHandle[] _waitHandles = null;
private readonly Queue<T> _itemQueue = null;
private readonly Semaphore _itemQueueSemaphore = null;
private readonly ManualResetEvent _itemQueueReleaseEvent = null;
// Constructors
public BlockingQueue()
{
// Default
_itemQueue = new Queue<T>();
_itemQueueSemaphore = new Semaphore(0, int.MaxValue);
_itemQueueReleaseEvent = new ManualResetEvent(false);
_waitHandles = new WaitHandle[] { _itemQueueSemaphore, _itemQueueReleaseEvent };
}
// Methods
public void Enqueue(T item)
{
lock (_syncRoot)
{
_itemQueue.Enqueue(item);
_itemQueueSemaphore.Release();
}
}
public T Dequeue()
{
WaitHandle.WaitAny(_waitHandles);
lock (_syncRoot)
{
if (_itemQueue.Count > 0)
{
return _itemQueue.Dequeue();
}
}
return default(T);
}
public void Release()
{
lock (_syncRoot)
{
_itemQueueReleaseEvent.Set();
}
}
public void Reset()
{
lock (_syncRoot)
{
_itemQueue.Clear();
_itemQueueSemaphore.Close();
_itemQueueReleaseEvent.Reset();
}
}
}
}
相关文章
asp.net模板引擎Razor中cacheName的问题分析
这篇文章主要介绍了asp.net模板引擎Razor中cacheName的问题,实例分析了cacheName在提高编译效率方面的使用技巧,需要的朋友可以参考下2015-06-06
Entity Framework使用Code First模式管理存储过程
本文详细讲解了Entity Framework使用Code First模式管理存储过程的方法，文中通过示例代码介绍的非常详细。对大家的学习或工作具有一定的参考借鉴价值，需要的朋友可以参考下2022-03-03
本文介绍使用 C# 编写一个 .NET 程序来自动化地使用 git 命令行来操作 git 仓库。小编觉得挺不错的，现在分享给大家，也给大家做个参考。一起跟随小编过来看看吧2019-04-04
MVC使用Memcache+Cookie解决分布式系统共享登录状态学习笔记6
这篇文章主要介绍了MVC使用Memcache+Cookie解决分布式系统共享登录状态学习笔记,具有一定的参考价值，感兴趣的小伙伴们可以参考一下2016-09-09
这篇文章主要为大家详细介绍了.Net MVC 网站中配置文件的读写，感兴趣的小伙伴们可以参考一下2016-08-08
这篇文章介绍了ASP.NET延迟调用或多次调用第三方Web API服务的方法，文中通过示例代码介绍的非常详细。对大家的学习或工作具有一定的参考借鉴价值，需要的朋友可以参考下2022-10-10
这篇文章主要给大家介绍了关于mysql安装后.net程序运行出错的解决方法，文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值，需要的朋友们下面随着小编来一起学习学习吧。2018-02-02
详解在DevExpress程序中使用TreeList控件以及节点查询的处理
本篇文章主要介绍基于DevExpress的TreeList控件使用以及使用SearchControl对节点进行查询的操作，具有一定的参考价值，下面跟着小编一起来看下吧2016-12-12
这篇文章主要给大家介绍了关于.Net集合排序的一种高级玩法的相关资料，文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值，需要的朋友们下面随着小编来一起学习学习吧2018-05-05
这篇文章主要给大家介绍了关于.net core整合log4net的解决方案，文中通过图文介绍的非常详细，对大家学习或者使用.net core具有一定的参考学习价值，需要的朋友们下面随着小编来一起学习学习吧2018-07-07
最新评论