实例解析C++/CLI线程之线程状态持久性

其他形式的同步

我们可使用类Monitor与类Thread中的某些函数，直接控制线程的同步，请看例1。

例1：

using namespace System;
using namespace System::Threading;
int main()
{
　 /*1*/ MessageBuffer^ m = gcnew MessageBuffer;
　 /*2a*/ ProcessMessages^ pm = gcnew ProcessMessages(m);
　 /*2b*/ Thread^ pmt = gcnew Thread(gcnew ThreadStart(pm,&ProcessMessages::ProcessMessagesEntryPoint));
　 /*2c*/ pmt->Start();
　 /*3a*/ CreateMessages^ cm = gcnew CreateMessages(m);
　 /*3b*/ Thread^ cmt = gcnew Thread(gcnew ThreadStart(cm, &CreateMessages::CreateMessagesEntryPoint));
　 /*3c*/ cmt->Start();
　 /*4*/ cmt->Join();
　 /*5*/ pmt->Interrupt();
　 /*6*/ pmt->Join();
　 Console::WriteLine("Primary thread terminating");
}
public ref class MessageBuffer
{
　 String^ messageText;
　 public:
　　 void SetMessage(String^ s)
　　 {
　　　 /*7*/ Monitor::Enter(this);
　　　 messageText = s;
　　　 /*8*/ Monitor::Pulse(this);
　　　 Console::WriteLine("Set new message {0}", messageText);
　　　 Monitor::Exit(this);
　　 }
　　 void ProcessMessages()
　　 {
　　　 /*9*/ Monitor::Enter(this);
　　　 while (true)
　　　 {
　　　　 try
　　　　 {
　　　　　 /*10*/ Monitor::Wait(this);
　　　　 }
　　　　 catch (ThreadInterruptedException^ e)
　　　　 {
　　　　　 Console::WriteLine("ProcessMessage interrupted");
　　　　　 return;
　　　　 }
　　　　 Console::WriteLine("Processed new message {0}", messageText);
　　　 }
　　　 Monitor::Exit(this);
　　 }
};
public ref class CreateMessages
{
　 MessageBuffer^ msg;
　 public:
　　 CreateMessages(MessageBuffer^ m)
　　 {
　　　 msg = m;
　　 }
　　 void CreateMessagesEntryPoint()
　　 {
　　　 for (int i = 1; i <= 5; ++i)
　　　 {
　　　　 msg->SetMessage(String::Concat("M-", i.ToString()));
　　　　 Thread::Sleep(2000);
　　　 }
　　　 Console::WriteLine("CreateMessages thread terminating");
　　 }
};
public ref class ProcessMessages
{
　 MessageBuffer^ msg;
　 public:
　　 ProcessMessages(MessageBuffer^ m)
　　 {
　　　 msg = m;
　　 }
　　 void ProcessMessagesEntryPoint()
　　 {
　　　 msg->ProcessMessages();
　　　 Console::WriteLine("ProcessMessages thread terminating");
　　 }
};

在标记1中，创建一个MessageBuffer类型的共享缓冲区；接着在标记2a、2b、2c中，创建了一个线程用于处理放置于缓冲区中的每条信息；标记3a、3b和3c，也创建了一个线程，并在共享缓冲区中放置了连续的5条信息以便处理。这两个线程已被同步，因此处理者线程必须等到有"东西"放入到缓冲区中，才可以进行处理，且在前一条信息被处理完之前，不能放入第二条信息。在标记4中，将一直等待，直到创建者线程完成它的工作。

当标记5执行时，处理者线程必须处理所有创建者线程放入的信息，因为使用了Thread::Interrupt让其停止工作，并继续等待标记6中调用的Thread::Join，这个函数允许调用线程阻塞它自己，直到其他线程结束。（一个线程可指定一个等待的最大时间，而不用无限等待下去。）

线程CreateMessages非常清晰明了，它向共享缓冲区中写入了5条信息，并在每条信息之间等待2秒。为把一个线程挂起一个给定的时间

凌众科技专业提供服务器租用、服务器托管、企业邮局、虚拟主机等服务，公司网站：http://www.lingzhong.cn 为了给广大客户了解更多的技术信息，本技术文章收集来源于网络,凌众科技尊重文章作者的版权，如果有涉及你的版权有必要删除你的文章，请和我们联系。以上信息与文章正文是不可分割的一部分,如果您要转载本文章,请保留以上信息，谢谢!