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

作者：佚名来源：不详发布时间：2006-12-29 13:41:43

其他形式的同步

　　我们可使用类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秒。为把一个线程挂起一个给定的时间（以毫秒计），我们调用了Thread::Sleep，在此，一个睡眠的线程可再继续执行，原因在于运行时环境，而不是另一个线程。

　　线程ProcessMessages甚至更加简单，因为它利用了类MessageBuffer来做它的所有工作。类MessageBuffer中的函数是被同步的，因此在同一时间，只有一个函数能访问共享缓冲区。

　　主程序首先启动处理者线程，这个线程会执行ProcessMessages，其将获得父对象的同步锁；然而，它立即调用了标记10中的Wait函数，这个函数将让它一直等待，直到再次被告之运行，期间，它也交出了同步锁，这样，允许创建者线程得到同步锁并执行SetMessage。一旦函数把新的信息放入到共享缓冲区中，就会调用标记8中的Pulse，其允许等待同步锁的任意线程被唤醒，并继续执行下去。但是，在SetMessage执行完成之前，这些都不可能发生，因为它在函数返回前都不可能交出同步锁。如果情况一旦发生，处理者线程将重新得到同步锁，并从标记10之后开始继续执行。此处要说明的是，一个线程即可无限等待，也可等到一个指定的时间到达。插1是程序的输出。

　　插1：

Set new message M-1
Processed new message M-1
Set new message M-2
Processed new message M-2
Set new message M-3
Processed new message M-3
Set new message M-4
Processed new message M-4
Set new message M-5
Processed new message M-5
CreateMessages thread terminating
ProcessMessage interrupted
ProcessMessages thread terminating
Primary thread terminating

　　请仔细留意，处理者线程启动于创建者线程之前。如果以相反的顺序启动，将会在没有处理者线程等待的情况下，添加第一条信息，此时，没有可供唤醒处理者线程，当处理者线程运行到它的第一个函数调用Wait时，将会错过第一条信息，且只会在第二条信息存储时被唤醒。

管理线程

　　默认情况下，如果一个线程是前台线程，它将会一直执行下去，直到进入点函数结束，而不管它父类的生命期是多久；而在另一方面，后台线程则会在父类线程结束时自动结束。可通过设置Thread的IsBackground属性，把一个线程配置为后台线程，用同样的方法，也可把一个后台线程配置为前台线程。

　　一旦线程被启动，它即为活跃线程，可通过检查Thread的IsAlive属性来判断一个线程是否为活跃线程；通过调用Wait函数，并传递给它一个零毫秒，可使一个线程放弃剩余的CPU时间片；另外，线程还可通过CurrentThread::Thread::CurrentThread属性得到其自己的Thread对象。

　　每个线程都有与之相关的优先级，运行时环境（即操作系统）通过它来调度线程的执行，可通过

[1] [2] 下一页

上一篇文章：利用VC# 2005为数码照片添加拍照日期

下一篇文章：利用Visual C++设置桌面墙纸

阅读统计:[]

【中国下载站】【设为主页】【收藏本页】【打印本文】【回到顶部】【关闭此页】

文章评论（评论内容只代表网友观点，与本站立场无关！）

栏目导航

分类广告