线程的创建

CBrother通过CreateThread方法创建多线程

function MulThreadFunc(param)
{
	print "MulThreadFunc param:" + param " threadid:" + GetThreadID();
}

function main(param)
{
	var threadid = CreateThread(MulThreadFunc,1);			//第一个参数是函数，第二个参数是传递的参数
	print "CreateThread threadid:" + threadid;
	threadid = CreateThread(MulThreadFunc,2);
	print "CreateThread threadid:" + threadid;
}

结果:

CreateThread threadid:13241
CreateThread threadid:4637
MulThreadFunc param:1 threadid:13241
MulThreadFunc param:2 threadid:4637

线程同步 Lock

多线程同时修改同一个数据，只有一个线程会修改成功，其他线程将抛出SyncException

故多线程修改同一个数据的时候一定要用Lock类来做线程之间的同步

var myLock = new Lock();

例子:

var g_count = 0;
var g_lock = new Lock();
function MulThreadFunc(param)
{
	for(var i = 0 ; i < 10 ; i++)
	{
		g_lock.lock();
		g_count++;
		print "MulThreadFunc param:" + param + " g_count:" + g_count;
		g_lock.unlock();	
	}
}

function main(param)
{
	CreateThread(MulThreadFunc,1);
	CreateThread(MulThreadFunc,2);

	while(g_count != 20)
	{
		Sleep(1000);
	}
}

结果:

MulThreadFunc param:1 g_count:1
MulThreadFunc param:2 g_count:2
MulThreadFunc param:1 g_count:3
MulThreadFunc param:2 g_count:4
MulThreadFunc param:2 g_count:5
MulThreadFunc param:1 g_count:6
MulThreadFunc param:2 g_count:7
MulThreadFunc param:1 g_count:8
MulThreadFunc param:1 g_count:9
MulThreadFunc param:2 g_count:10
MulThreadFunc param:2 g_count:11
MulThreadFunc param:2 g_count:12
MulThreadFunc param:2 g_count:13
MulThreadFunc param:2 g_count:14
MulThreadFunc param:1 g_count:15
MulThreadFunc param:2 g_count:16
MulThreadFunc param:1 g_count:17
MulThreadFunc param:1 g_count:18
MulThreadFunc param:1 g_count:19
MulThreadFunc param:1 g_count:20

Thread 类

CBrother提供了Thread类，它有定时器功能，也可以处理线程消息

thread对象销毁时，线程会停止。但如果thread对象被action对象引用，则线程不会停止。建议在不用线程的时候主动停止。

Thread响应Action类可以有如下接口

function onInit()，线程启动初始化。

function onEnd()，线程结束时。

function onMsg(msg)，接收线程消息。

例子:

class ThreadMsg
{
	var msgid;
}
class ThreadAction
{
	var thread;
	
	function ThreadAction(t)
	{
		thread = t;
		this.thread.addTimer(1000,onHeart1);
		this.thread.addTimer(1000,onHeart2,2);
	}
	
	function onInit()
	{
		print "thread init" ;
	}
	
	function onMsg(msg)
	{
		print "msg id:" + msg.msgid;
	}
	
	function onEnd()
	{
		print "thread end";
	}
	
	function onHeart1()
	{
		print "in action heart1";
	}
	
	function onHeart2()
	{
		print "in action heart2";
	}
}

class testHeart
{
	function onTestHeart()
	{
		print "in testHeart";
	}
}

function TestTime()
{
	print "in time1";
}

function TestTime2()
{
	print "in time2";
}

function main(param)
{
	var thread = new Thread();
	thread.addTimer(1000,TestTime);
	thread.addTimer(1000,TestTime2,2);
	thread.addTimer(1000,new testHeart().onTestHeart);
	thread.setThreadAction(new ThreadAction(thread));
	thread.start();
	
	var i = 0;
	while(1)
	{
		Sleep(1000);
		var msg = new ThreadMsg();
		msg.msgid = i++;
		thread.addMsg(msg);		
		if(i >= 5)
		{
			break;
		}
	}
	thread.stop();
}

结果:

thread init
msg id:0
in time1
in time2
in testHeart
in action heart1
in action heart2
msg id:1
in time1
in time2
in testHeart
in action heart1
in action heart2
msg id:2
in time1
in testHeart
in action heart1
msg id:3
in time1
in testHeart
in action heart1
msg id:4
thread end

Event 类

多线程编程中，经常需要某个线程在等待其它线程做完一些处理后才能继续执行。CBrother提供了Event类来做这样的事情。

var myEvent = new Event();

例子:

var g_count = 0;
var g_lock = new Lock();
var g_Event = new Event();
function MulThreadFunc(param)
{
	if(param == 1)
	{
		print "wait in thread:" + param;
		g_Event.wait(3000);	//等待3秒
		print "wait end in thread:" + param;
	}
	
	for(var i = 0 ; i < 10 ; i++)
	{
		g_lock.lock();
		g_count++;
		print "MulThreadFunc param:" + param + " g_count:" + g_count;
		g_lock.unlock();	
	}
	
	if(g_Event.endWait())
	{
		print "endWait suc in thread:" + param;
	}
	else
	{
		print "endWait faile in thread:" + param;
	}
}

function main(param)
{
	CreateThread(MulThreadFunc,1);
	CreateThread(MulThreadFunc,2);

	while(g_count != 20)
	{
		Sleep(1000);
	}
}

结果:

wait in thread:1
MulThreadFunc param:2 g_count:1
MulThreadFunc param:2 g_count:2
MulThreadFunc param:2 g_count:3
MulThreadFunc param:2 g_count:4
MulThreadFunc param:2 g_count:5
MulThreadFunc param:2 g_count:6
MulThreadFunc param:2 g_count:7
MulThreadFunc param:2 g_count:8
MulThreadFunc param:2 g_count:9
MulThreadFunc param:2 g_count:10
endWait suc in thread:2
wait end in thread:1
MulThreadFunc param:1 g_count:11
MulThreadFunc param:1 g_count:12
MulThreadFunc param:1 g_count:13
MulThreadFunc param:1 g_count:14
MulThreadFunc param:1 g_count:15
MulThreadFunc param:1 g_count:16
MulThreadFunc param:1 g_count:17
MulThreadFunc param:1 g_count:18
MulThreadFunc param:1 g_count:19
MulThreadFunc param:1 g_count:20
endWait faile in thread:1