我正在使用 Glade、python 和 pygtk 开发一个非常基本的 GUI,它将根据通过 UDP 套接字接收的实时数据进行自我更新。接收到的数据包每 256 毫秒发送一次。据我了解,我需要使用线程接收这些数据,以在接收数据时保持我的 GUI 响应。我已经尝试这样做。结果 GUI 会打开,但我没有从我的 UDP(dpmserver 线程)获得任何 OP . 我已经单独尝试了 dpmserver 模块,它工作正常。我是线程新手。实际上,这是我在 python 中使用线程的第一个程序。如何让我的 GUI 保持响应并同时接收数据?代码如下:
TMSTART=41
PACKETSIZE=133
FIELD=9
TMEND=(PACKETSIZE-1)-FIELD
import socket
import sys
import string
import os.path
import urllib2
import string
import linecache
from pprint import pprint,pformat
import threading
try:
import pygtk
pygtk.require("2.0")
except:
print "You need to install pyGTK or GTKv2 or set your PYTHONPATH correctly"
sys.exit(1)
import gtk
import gtk.glade
def procpack(data):
TMlist=[]
for i in range(TMSTART,TMEND,FIELD):
field=data[i+1:i+FIELD+1]
try:
if field=='\x00\x00\x00\x00\x00\x00\x00\x00\x00':
return TMlist
except:
pass
TMlist.append([field[0:8],field[8]])
def dpmserver():
server_socket = socket.socket(socket.AF_INET, socket.SOCK_DGRAM)
server_socket.bind(("", 5123))
print"UDPServer Waiting for client on port 5123"
bytestack=[];
while 1:
data, address = server_socket.recvfrom(512)
print "( " ,address[0], " " , address[1] , " ) said : ", data," length:",len(data)
print procpack(data)
class AppParafin:
def __init__(self):
self.gladefile = 'dpm.glade'
windowname = 'Deployment Monitor'# This must match the window name in glade
self.wTree = gtk.glade.XML(self.gladefile, windowname)# object for acessing widgets
t=threading.Thread(target=dpmserver)
t.start()
self.op=self.wTree.get_widget('Deployment Monitor')
self.op.show()
app = AppParafin()
gtk.main()