线程在while循环执行期间停止

2024-06-16 11:42:19 发布

您现在位置:Python中文网/ 问答频道 /正文

我有一个用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

代码是@https://github.com/sagar1805/usrp-server.git


Tags: selfrestisdef线程fnameprintfrequency