我有一个用python编写的线程类(TransmitThread),它只接受很少的参数,然后开始向设备(niusrp)传输。 我有一个基于rest flask的webservice,它根据用户的rest请求创建一个新的TransmitThread对象并调用start()。理想情况下,它应该开始传输并等待自转我可以伪造。 我发现我的实现有两个问题 1我没有看到线程类的指纹 2我把这些线索存到字典里作为参考。当我得到一个后续的rest请求时,旧线程处于stopped状态。你知道吗
注意:我不太熟悉Python,我正在努力学习,所以任何额外的输入也会很有帮助
任何关于如何保持线程运行和日志打印的输入都会有所帮助。你知道吗
class TransmitThread(threading.Thread,grc_wxgui.top_block_gui):
// variables are initalised here
thdRunning = True
def __int__(self):
pass
def run(self):
##################################################
# Variables
##################################################
self.samp_rate = samp_rate = 32000
....do some more thing....
print("Transmission started! Will wait to be killed")
while self.thdRunning:
time.sleep(2)
print("Transmission thread stopped!")
def endThreadExecution(self):
self.thdRunning = False;
rest服务实现
@app.route('/txdata/<clienID>/<usrpIp>/<frequency>/<path:fname>',methods=['GET'])
def transmit(clienID,usrpIp,frequency,fname):
global dict
if(not isUsrptransmiting)|shallStartTxn:
if fname.endswith('.iq12'):
decIM = 12
else:
decIM = 48
usrpIp = "addr="+str(usrpIp)
print(usrpIp)
fname = "/"+fname
transmitThread = threading.Thread(target=TransmitThread,args=(fname, str(usrpIp), decIM, frequency))
transmitThread.daemon = True # Daemonize thread
print("Service is Transmitting " + str(clienID) + "this is your username " + str(usrpIp) + " freq " + str(frequency) + " file " + str(fname) +" decIM "+str(decIM))
transmitThread.start()
dict[str(usrpIp)] = transmitThread
print('Service is Transmitting '+ clienID+',this is your username '+usrpIp+ ' freq '+frequency+ ' file '+ fname)
response = {'clientId':clientID}
else:
response = {'clientId':"None"}
return jsonify(response),200
目前没有回答
相关问题 更多 >
编程相关推荐