用PB编写多线程应用程序
2024-07-21 02:10:23
供稿：网友
多线程是指一个程序内部同时执行的多个流程，与单线程相比，它至少有两个方面的优点：第一，它可以更好地利用系统资源，比如cpu，若一个线程因i/o操作受阻，另一个线程仍可利用cpu来执行；第二，它更好地满足了客户的需求，因为挑剔的客户希望你开发的程序在显示动画的同时还能播放音乐、显示文件、下载网络文件等，这是单线程应用程序无法完成的。目前，支持多线程的开发工具主要有：java、vc、delphi和c＋＋builder。
多线程强调的是一个进程内部有多个流程在同时执行，同时执行的概念相当于pb分布式计算中的异步处理。也就是说，只要我们在一个程序内部实现了异步处理，就相当于实现了多线程。分析至此，下一步该怎么做就不言而喻了：在一个应用程序内部实现分布式计算，使用服务器推送技术，异步执行共享对象中的函数。
下面就编写一个demo，介绍在pb中如何利用分布式计算技术来开发多线程应用程序，其程序结构如图1所示。uo—thread1和uo—thread2是类用户对象uo—thread的两个实例，uo—thread的功能是给实例变量li—count自加5秒，自加的同时向中间对象uo—argv1和uo—argv2发送ue—thread消息。两个中间对象的功能是把ue—thread消息转化为ue—thread1和ue—thread2后发给主窗口w—main。
图1 程序结构
主窗口接收到ue—thread1消息后，显示uo—thread1中自加变量的值，接收到ue—thread2后，显示uo—thread2中自加变量的值。在单线程中，uo—thread1先执行，5秒钟后uo—thread2开始执行，因此，前5秒内主窗口只能收到ue—thread1消息，后5秒内只能收到ue—thread2消息。在多线程中，uo—thread1和uo—thread2同时执行，因此w—main可以不断地收到ue—thread1和ue—thread2消息。
1．设计用户对象uo—thread
新建一个类用户对象，命名为uo—thread，添加如下两个实例变量：
nonvisualobject inv—arg
long li—count //自加变量
创建如下三个用户函数：
⑴uf—start()，功能是：完成自加5秒并向中间对象发送ue—thread消息。脚本为：
time t0
t0= now() //获取当前时间
do while secondsafter(t0,now())〈=5
li—count＋＋//实例变量自加5秒
inv—arg.triggerevent(′ue—thread′)
//向中间对象发送ue—thread消息
loop
⑵uf—getcount()，功能是：获取自加变量的瞬间值。其脚本为：
return li—count //返回实例变量
⑶uf—setparent(nonvisualobject nv—arg)，调用时，使用中间对象为参数。脚本为：
inv—arg=nv—arg
//用中间对象给实例变量赋值
2．设计中间对象uo—argv1和uo—argv2
新建一个类用户对象，命名为uo—argv1，添加如下实例变量：
window win—arg
创建用户函数uf—setparent(window w—argv)，调用时，用主窗口作为参数。其脚本为：
win—arg=w—argv
//用主窗口对象给实例变量赋值
声明用户事件ue—thread，用于对uo—thread1发出的uo—thread消息进行响应，其脚本为：
win—arg.triggerevent(″ue—thread1″)
//向主窗口发送ue—thread1消息
uo—argv2和uo—argv1完全一样，只需将uo—argv1中的ue—thread1改为uo—thread2即可。
3．设计主窗口w—main
主窗口外观如图2所示，凹下的三个控件分别为：st—thread1、st—thread2、st—time，分别用于显示uo—thread1和uo—thread2中自加变量的当前瞬间值和系统时间。声明两个用户事件：ue—thread1和ue—thread2，分别用于对中间对象发送来的ue—thread1和ue—thread2消息进行响应。ue—thread1事件处理代码为：
图2 主窗口
st—thread1.text=string(uo—thread1.uf—getcount())
ue—thread2事件的处理代码为：
st—thread2.text=string(uo—thread2.uf—getcount())
w—main的open事件代码为：
uo—arg1 = create uo—argv1
//初始化中间对象的一个实例
uo—arg2 = create uo—argv2
uo—arg1.uf—setparent(this) //给中间对象的实例变量赋值
uo—arg2.uf—setparent(this)
timer(1) //启动定时器
timer事件处理代码为：
st—time.text=string(now())//显示当前时间
在“单线程”的clicked事件中加入下列代码：
sharedobjectunregister(″object1″)
//注销先前注册过的共享对象object1
sharedobjectunregister(″object2″)
//注销先前注册过的共享对象object2
if isvalid(uo—thread1) then destroy uo—thread1 //若uo—thread1已经存在，先删除
if isvalid(uo—thread2) then destroy uo—thread2
uo—thread1=create uo—thread
//初始化uo—thread1
uo—thread2=create uo—thread
uo—thread1.uf—setparent(uo—argv1) //用中间对象给uo—thread1中的实例变量赋值
uo—thread2.uf—setparent(uo—argv2)
uo—thread1.post uf—start() //执行uo—thread1中的uf—start()函数，完成后才执行下一句
uo—thread2.post uf—start()
//上一条语句执行完成后才会执行
在“多线程”的clicked事件中加入下列代码：
sharedobjectregister(″uo—thread″,″object1″)
//将uo—thread对象注册为object1
sharedobjectregister(″uo—thread″,″object2″)
//将uo—thread对象注册为object2
sharedobjectget(″object1″,uo—thread1)
//用uo—thread1引用共享对象object1
sharedobjectget(″object2″,uo—thread2)
//用uo_thread2引用共享对象object2
uo—thread1.uf—setparent(uo—argv1) //用中间对象给uo—thread1中的实例变量赋值
uo—thread2.uf—setparent(uo—argv2)
uo—thread1.post uf—start() //利用服务器推送技术，异步调用共享对象中的uf—start()
uo—thread2.post uf—start()//相当于启动线程
4．执行
执行程序后，图2就是点击“多线程”后执行的一瞬间
