Python3结合Sciter编写桌面程序第二节

第二节 将任务添加到队列!

上一个栗子只是简单实现了下网页与后台的通信

def clickMe(self):#你可以在这里处理任何你想要的操作self.call_function(&＃39;clickCallBack&＃39;,&＃39;你已经点到我了!&＃39;)

但由于是同一个进程&＃xff0c;如果你做了很耗时的操作&＃xff0c;比如下载一张图片之类的IO操作......

你会发现&＃xff0c;窗口卡住了&＃xff0c;一般表现为窗口泛白&＃xff0c;出现未响应的提示......但这并不是程序真的未响应了&＃xff0c;等图片下载完就会恢复原样。

但是&＃xff0c;你能接受吗&＃xff1f;

如果能的话......下面就可以不用看了&＃xff0c;我说真的。

咳...嗯

继续

为了不卡&＃xff0c;我选择了多进程的方式&＃xff0c;多线程也可以&＃xff0c;但万一这个线程死掉&＃xff0c;会拉着主线程下水......以防万一&＃xff0c;我选择再开一个进程作为服务进程。

from multiprocessing import Process,Queue# 创建用于接收服务进程传递的回馈任务的队列&＃xff0c;此队列线程安全
self.GuiQueue &＃61; Queue()
# 创建用于接收界面进程发送的任务的队列&＃xff0c;此队列线程安全
self.ServiceQueue &＃61; Queue()
p &＃61; Process(target &＃61; startServiceP, args &＃61; ( self.GuiQueue, self.ServiceQueue ))
p.daemon &＃61; True #设置为守护进程,保证主进程退出时子进程也会退出
p.start()

为何选用Process及Queue?

单纯开启一个子进程或许还有一个更好的选择&＃xff1a;Popen&＃xff0c;它可以启动独立的py脚本作为子进程&＃xff0c;也有很多方法可供选择。但我不知道应该如何通信及传参&＃xff0c;找了一些栗子&＃xff0c;无奈无法完全理解&＃xff0c;只能待日后解决。

Python多进程通信方法有Queue、Pipe、Value、Array

• pipe用来在两个进程间通信
• queue用来在多个进程间实现通信
• Value &＃43; Array 是python中共享内存映射文件的方法

最初的设计比现在复杂&＃xff0c;共有3个进程&＃xff0c;故弃用pipe

Value &＃43; Array的方式当时没找到&＃xff0c;遗漏

只剩Queue......

据说Queue速度上慢一些&＃xff0c;但以咱目前的水平&＃xff0c;速度不是瓶颈

够用就行&＃xff0c;不是吗&＃xff1f;

pipe后期也会研究的就是了......

我们来看一下这个服务进程有些啥

def startServiceP(_GuiQueue, _ServiceQueue):&＃39;&＃39;&＃39;开启一个服务进程&＃39;&＃39;&＃39;funMap &＃61; ServiceEvent( _GuiQueue )EventManager( _ServiceQueue, funMap ).Start()

就这么简单~

funMap 是啥? ServiceEvent 又哪来的!? EventManager 又是什么鬼??!!

等下&＃xff0c;把刀放下......

咳...

一般来说&＃xff0c;从界面传来的命令都是字符串&＃xff0c;然后通过这个字符串来执行指定函数

funMap 就是存放的事先写好的函数字典

看一下ServiceEvent():

class ServiceEvent(object):&＃39;&＃39;&＃39;服务进程&＃39;&＃39;&＃39;def __init__(self, _GuiQueue):self.GuiQueue &＃61; _GuiQueuedef clickCallBack(self, msg):sleep(3)self.__putGui( &＃39;clickCallBack&＃39;, msg )def __putGui(self, f, m &＃61; None ):self.GuiQueue.put({&＃39;fun&＃39; : f,&＃39;msg&＃39; : m})

现在可以调用 funMap.clickCallBack()

关于 GuiQueue 等会再说&＃xff0c;先来看一下EventManager()

clickMe() 只是把要执行的任务发送给 ServiceQueue 了&＃xff0c;但此任务不会自动执行&＃xff0c;我们还需要一个循环来读取任务&＃xff0c;这就是EventManager()的功能。

EventManager()核心代码&＃xff1a;

def __Run(self):while self.__active &＃61;&＃61; True:try:# 获取事件的阻塞时间设为1秒event &＃61; self.Queue.get(timeout &＃61; 1)getattr( self.funMap, event[&＃39;fun&＃39;] )( event[&＃39;msg&＃39;] ) #关键代码except Exception as e:pass

以上是服务进程的相关内容&＃xff0c;我们再回来看一下界面该如何及时获得反馈

from threading import Threadt &＃61; Thread(target &＃61; queueLoop, args&＃61;( self.GuiQueue, self.call_function ))
t.daemon &＃61; True
t.start()

嗯&＃xff0c;此处我开了另一个线程来执行这个循环&＃xff0c;老实说没想到特别好的办法&＃xff0c;这个循环肯定不能在主线程使用&＃xff0c;会卡界面的&＃xff0c;开一个进程又太小题大做&＃xff0c;折中方案&＃xff0c;用了多线程&＃xff0c;好在它只是遍历Queue&＃xff0c;没啥复杂的操作......

def queueLoop( _GuiQueue, funCall ):guiCallBack &＃61; GuiCallBack( funCall )EventManager( _GuiQueue, guiCallBack ).Start()

基本和服务进程一样&＃xff0c;不做过多解释了~

需要注意的只有 funCall这个参数&＃xff0c;很重要&＃xff0c;界面的事件调用全靠它。

Tis&＃xff1a;

$(.click-me).on("click",function(){view.clickMe(); //view Sciter内置的对象&＃xff0c;所有tis都可调用
})

main.py &＃xff1a;

# 导入sciter支持,必须安装pysciter
import sciter
import ctypes
import jsonfrom multiprocessing import Process,Queue
from threading import Thread
from EventManager import EventManager
from FunManager import ServiceEvent, GuiCallBack# 设置dpi, 防止程序在高分屏下发虚
ctypes.windll.user32.SetProcessDPIAware(2)def startServiceP(_GuiQueue, _ServiceQueue):&＃39;&＃39;&＃39;开启一个服务进程&＃39;&＃39;&＃39;funMap &＃61; ServiceEvent( _GuiQueue )EventManager( _ServiceQueue, funMap ).Start()def queueLoop( _GuiQueue, funCall ):guiCallBack &＃61; GuiCallBack( funCall )EventManager( _GuiQueue, guiCallBack ).Start()class Frame(sciter.Window):def __init__(self):&＃39;&＃39;&＃39;ismain&＃61;False, ispopup&＃61;False, ischild&＃61;False, resizeable&＃61;True,parent&＃61;None, uni_theme&＃61;False, debug&＃61;True,pos&＃61;None, pos&＃61;(x, y)size&＃61;None&＃39;&＃39;&＃39;super().__init__(ismain&＃61;True, debug&＃61;True)self.set_dispatch_options(enable&＃61;True, require_attribute&＃61;False)def _document_ready(self, target):&＃39;&＃39;&＃39;在文档加载后执行&＃xff0c;如果设置启动画面&＃xff0c;可以在这里结束&＃39;&＃39;&＃39;# 创建用于接收服务进程传递的回馈任务的队列&＃xff0c;此队列线程安全self.GuiQueue &＃61; Queue()# 创建用于接收界面进程发送的任务的队列&＃xff0c;此队列线程安全self.ServiceQueue &＃61; Queue()p &＃61; Process(target &＃61; startServiceP, args &＃61; ( self.GuiQueue, self.ServiceQueue ))p.daemon &＃61; True #设置为守护进程,保证主进程退出时子进程也会退出p.start()t &＃61; Thread(target &＃61; queueLoop, args&＃61;( self.GuiQueue, self.call_function ))t.daemon &＃61; Truet.start()def clickMe(self):# 点击页面上的按钮后&＃xff0c;只将任务添加到服务队列&＃xff0c;耗时很短&＃xff0c;因此不会发生界面卡顿现象self.__putService(&＃39;clickCallBack&＃39;,&＃39;你已经点到我了!&＃39;)def __putService(self, f, m &＃61; None):&＃39;&＃39;&＃39;接收界面事件并转发&＃39;&＃39;&＃39;self.ServiceQueue.put({&＃39;fun&＃39; : f,&＃39;msg&＃39; : m})if __name__ &＃61;&＃61; &＃39;__main__&＃39;:frame &＃61; Frame()frame.load_file("Gui/main.html")frame.run_app()


EventManager.py&＃xff1a;

class EventManager:def __init__(self, _Queue, funMap):self.__active &＃61; Falseself.Queue &＃61; _Queueself.funMap &＃61; funMapdef __Run(self):while self.__active &＃61;&＃61; True:try:# 获取事件的阻塞时间设为1秒event &＃61; self.Queue.get(timeout &＃61; 1)getattr( self.funMap, event[&＃39;fun&＃39;] )( event[&＃39;msg&＃39;] )except Exception as e:passdef Start(self):self.__active &＃61; Trueself.__Run()def Stop(self):self.__active &＃61; False

FunManager.py&＃xff1a;

from time import sleepclass ServiceEvent(object):&＃39;&＃39;&＃39;服务进程&＃39;&＃39;&＃39;def __init__(self, _GuiQueue):self.GuiQueue &＃61; _GuiQueuedef clickCallBack(self, msg):sleep(3)self.__putGui( &＃39;clickCallBack&＃39;, msg )def __putGui(self, f, m &＃61; None ):self.GuiQueue.put({&＃39;fun&＃39; : f,&＃39;msg&＃39; : m})class GuiCallBack(object):def __init__(self, funCall):self.funCall &＃61; funCalldef clickCallBack(self, msg):return self.funCall(&＃39;clickCallBack&＃39;, msg )

代码渐渐多了起来&＃xff0c;但效果还是很让人满意的。

缺点是一不留神容易出错

源码