同時運行Python線程

我想同時運行兩個函數，因爲我想繼續在套接字中發送和接收消息。這是我的主要功能，但我無法讓線程同時運行。只有發送正在運行。我怎樣才能解決這個問題？同時運行Python線程

def __init__(self): 
    d = {} 
    d["id"] = "MyId" 
    d["Count"] = 0 
    d["Message"] = "Just a little message for you" 
    self.d = d 

    restart = False 
    self.restart = self 

def sendMessage(self): 
    server = SocketServer.UDPServer((DEFAULT_IP, HOST_PORT), MyMessageHandler) 
    while True: 
     time.sleep(5) 
     sendData = json.dumps(self.d, ensure_ascii=False) 
     server.socket.sendto(sendData, (DEFAULT_IP, SENDING_PORT)) 
     self.restart = True 

def receiveMessages(self): 
    #I know there isn't a message being received. The count is an example of me 
    #'receiving' data and then sending it out 
    msg_count = 0 
    while True: 
     if self.restart == True: 
      msg_count = 0 
      self.d["Count"] = 0 
      self.restart = False 
     else: 
      msg_count += 1 
      self.d["Count"] = msg_count 
def main(self): 
    receiving = threading.Thread(target=self.receiveMessages) 
    sending = threading.Thread(target=self.sendMessage(self.d)) 
    receiving.start() 
    sending.start() 

    receiving.join() 
    sending.join()

來源

2017-05-26 user3358710

你能分享在兩個線程中運行的代碼嗎？ – srfrnk

多重處理對你沒用嗎？ – Mikael

@srfrnk我將代碼添加到問題 – user3358710

您對sending = threading.Thread(target=self.sendMessage(self.d))調用實際上調用該函數sendMessages。這個函數被阻塞，永遠不會返回，因此代碼將永遠不會到達receiving.start()，接收線程將永遠不會運行。

更改爲sending = threading.Thread(target=self.sendMessage)，所有將開始工作。

來源

2017-05-28 04:49:47 srfrnk

謝謝！這絕對是我的錯誤，因爲我沒有爲第一個線程添加括號。 – user3358710

不客氣。很高興我能幫上忙。 – srfrnk

問題：只發送運行。我怎樣才能解決這個問題？

你sendMessage(self.d)爲你傳遞method sendMessage(self.d)到target參數的結果只執行一次。
更改爲

sending = threading.Thread(target=self.sendMessage)

來源

2017-05-27 15:57:11 stovfl

同時運行Python線程

回答

相關問題