python - 如何使用 Gtk.events_pending?
问题描述
我有这个基本的“测试”应用程序,我想在其中显示一个微调器,同时它正在执行其长时间的启动过程(具有数据库请求的功能),让用户知道它不是窃听而是启动。我在其他帖子中读到可以使用Gtk.events_pending()
函数来执行此操作,但我不知道如何/在哪里使用它。我尝试了很多方法,但主窗口始终仅在请求完成时显示:
这是主要的 .py 文件:
#!/usr/bin/python3
# -*- coding: Utf-8 -*-
import gi
gi.require_version('Gtk', '3.0')
from gi.repository import Gtk, Gdk, GdkPixbuf, GObject
import Mng,os.path
path = os.path.dirname(os.path.realpath(__file__))
# MAIN WINDOW ######################################################################################
class PyApp:
def __init__(self):
builder = Gtk.Builder()
builder.add_from_file(path + "/test.glade")
self.obj = builder.get_object
"""
I would like to display on main window a
spinner while doing requests. There is a
self.obj('spinner') in main window,
in glade file to do so.
"""
self.do_requests()
self.obj('main').show_all()
def do_requests(self):
mng = Mng.Grab([
[1,'getPlayers'],
[2,'getFactions'],
[3,'getBoards']
])
data = mng.grab_data()
players, nb = data[1]
factions, nb = data[2]
boards, nb = data[3]
"""
Here will be the code to display data in GUI,
like for example : self.obj('label_players').set_text(str(players))
"""
if __name__ == "__main__":
app = PyApp()
Gtk.main()
这是 Mng.py 文件,我将在其中管理一个类中的所有请求(我不知道它是否编码良好,因为我刚刚发现了多线程。但它确实有效):
#!/usr/bin/python3
# -*- coding: Utf-8 -*-
import os.path, DB
import concurrent.futures
path = os.path.dirname(os.path.realpath(__file__))
class Grab:
"""
Retrieves multiple database requests datas
& returns results in a dict : {name of request: [result, lenght of result]}
"""
def __init__(self, req_list):
self.req_list = req_list
def grab_data(self):
def do_req(var, funct_name, args):
if None in args:
funct = getattr(self, str(funct_name))()
else:
#print("function",name,"*args : ", *args)
funct = getattr(self, str(funct_name))(*args)
res = [var, funct]
return res
with concurrent.futures.ThreadPoolExecutor(max_workers=5) as executor:
res_list = {}
future_to_req = {executor.submit(do_req, req[0], req[1], req[2:]): req for req in self.req_list}
for future in concurrent.futures.as_completed(future_to_req):
req = future_to_req[future]
try:
data = future.result()
except Exception as exc:
print('%r generated an exception: %s' % (req, exc))
else:
res_list[data[0]] = data[1]
return res_list
def getFactions(self, ext1=False):
req = DB.DB('SELECT * FROM factions')
res = req.res
nb = len(res)
return res, nb
def getBoards(self, ext1=False):
req = DB.DB('SELECT * FROM boards')
res = req.res
nb = len(res)
return res, nb
def getPlayers(self):
req = DB.DB('SELECT * FROM players')
res = req.res
nb = len(res)
return res, nb
并且 DB.py 文件执行请求:
#!/usr/bin/python3
# -*- coding: Utf-8 -*-
import mysql.connector as sql
class DB(object):
"""DB initializes and manipulates MySQL databases."""
def __init__(self, query):
"""Initialize a new or connect to an existing database.
Accept setup statements to be executed.
"""
self.database = '******'
self.host = '**********'
self.port = '********'
self.user = '******'
self.password = '***********'
self.connect()
self.execute(query)
self.close()
def connect(self):
"""Connect to the MySQL database."""
self.connection = sql.connect(host=self.host,port=self.port,user=self.user,password=self.password, database=self.database)
self.cursor = self.connection.cursor()
self.connected = True
def close(self):
"""Close the MySQL database."""
self.connection.close()
self.connected = False
def execute(self, query):
"""Execute complete SQL statements. """
res = close = False
if not self.connected:
self.connect()
close = True
try:
self.cursor.execute(query)
if query.upper().startswith('SELECT'):
res = self.cursor.fetchall()
except sql.Error as e:
try:
print ("MySQL Error [%d]: %s" % (e.args[0], e.args[1]))
except IndexError:
print ("MySQL Error: %s" % str(e))
if close:
self.close()
self.res = res
你能告诉我怎么做吗?
解决方案
这可以帮助您了解多处理应该如何工作。抱歉,我不能给你一个完整的演示,里面有你的代码,但希望你能弄明白。
#!/usr/bin/env python3
from gi.repository import Gtk, GLib, Gdk
from multiprocessing import Queue, Process
from queue import Empty
import os, sys, time
UI_FILE = "src/pygtk_foobar.ui"
class GUI:
def __init__(self):
self.builder = Gtk.Builder()
self.builder.add_from_file(UI_FILE)
self.builder.connect_signals(self)
self.window1 = self.builder.get_object('window1')
self.window1.show_all()
self.builder.get_object('spin1').start()
self.data_queue = Queue()
thread = Process(target=self.thread_start)
thread.start()
GLib.timeout_add(100, self.get_result )
def thread_start (self):
time.sleep(5)
self.data_queue.put("done")
def get_result (self):
try:
result = self.data_queue.get_nowait()
print (result)
self.builder.get_object('spin1').stop()
except Empty:
return True
def on_window_destroy(self, window):
Gtk.main_quit()
def main():
app = GUI()
Gtk.main()
if __name__ == "__main__":
sys.exit(main())
编辑
解释:只要get result
返回 True,GLib.timeout_add() 就会继续轮询。当超时返回 None 或 False 时,它将退出轮询。get result
将尝试从 data_queue 中获取结果,但如果没有找到,它将返回 True。
在您的情况下,您将打开数据库请求def thread_start
并检查队列,def get_result
直到信息已加载。所以多处理将在一个线程中加载数据库信息,而 Gtk 可以在另一个线程中进行窗口绘制,同时定期检查多处理数据库线程是否完成。完成加载后,通过不返回 True 来取消超时,然后使用 db 数据执行您的操作。
例如,当用户可以操作 GUI 时,我经常使用它来填充扫描仪。
希望这可以帮助。
推荐阅读
- php - 如何在 flex 环境和 PHP 运行时使用 GAE 处理 CORS(或任何标头)?
- python - 使用 while 循环检查小数点
- ansible - Ansible:如何将多个文件夹与库存文件中的路径分组
- javascript - Vue.js 应用程序中的预加载器?
- sql - 为什么不删除所有重复项?
- ruby-on-rails - Rails 从 4.2.5.1 升级到 4.2.7.1 中的 ActiveRecord 更改
- javascript - 将对象数组排序为更干净的数组
- firebase - 如何使用 AngularFire 将 firebase 数据库值检索到列表中
- swift - Firebase 跟踪框架
- python - BeautifulSoup 网页抓取 python。使用 click() 方法的未知错误