我正在做一个数据包生成器,它的关键是能够发送数据包尽可能稳定和准确。我遇到的问题是,我使用while循环发送数据包时间。睡眠这应该是循环数百次/秒,但由于它需要额外的和不断变化的时间通过循环,它很难设置一个正确的睡眠时间。你知道吗
下面是我使用的代码:
while status == "1":
try:
s.send(message)
data = s.recv(1500)
status = self.clientstatus
time.sleep(1.0 / (speed*100))
except:
status = "0"
编辑:
这是我使用的有效解决方案
def clientstart(self):
self.sch = sched.scheduler(time.time, time.sleep)
self.next_time = time.time()
self.sch.enterabs(self.next_time, 0, self.oneround, ())
self.reset.emit()
time.sleep(0.03)
n = 0
targetip = self.entry1.text()
host = targetip
port = 5001
speed = int(self.entry2.text())
self.delay = 1.0 / (speed*100)
if targetip:
self.s = socket.socket(socket.AF_INET6, socket.SOCK_DGRAM)
try:
self.s.connect((host,port))
except:
self.err1.emit(1)
n = n+1
openfile = open('1024')
self.message = openfile.read()
self.clientstatus = "1"
status = self.clientstatus
self.buttonswitch("2")
n = n+1
self.nn = 1
t = threading.Thread(target = self.temp)
t.setDaemon(True)
t.start()
self.err1.emit(2)
self.sch.run()
if n == 1:
self.err1.emit(4)
elif n == 4:
self.err1.emit(0)
self.s.close()
self.buttonswitch("3")
else:
self.err1.emit(3)
def oneround(self):
try:
self.s.send(self.message)
status = self.clientstatus
self.nn += 1
if status == '1':
self.next_time += self.delay
self.sch.enterabs(self.next_time, 0, self.oneround, ())
except:
pass
不过,在socket中使用self可能会在将来引起一些问题
安排周期性事件的最合理的方法之一是
sched
模块,该模块记录在https://docs.python.org/2/library/sched.html中,它与系统(当然不是实时系统)所允许的定期事件一样接近。你知道吗对于您的用例,我会尝试:
如果一个事件被延迟(我们不是在一个真正的硬时间环境中,因此操作系统可能会导致不可预测的延迟),那么每
1.0 / (speed*100)
秒这将尽可能接近一个事件,下一个事件将在未来更近的时间安排,&;c.当sch
中没有输入更多内容时,隐含的循环结束。你知道吗相关问题 更多 >
编程相关推荐