python並發編程:多線程-開啟線程的兩種方式
阿新 • • 發佈:2018-07-08
utf-8 data NPU pre int thread pro reading class
一 threading模塊介紹
multiprocess模塊完全模仿了threading模塊的接口,二者在使用層面,有很大的相似性
二 開啟線程的兩種方式
方式一
from threading import Thread import time def sayhi(name): time.sleep(2) print("%s say hello" % name) if __name__ == ‘__main__‘: t = Thread(target=sayhi, args=(‘mike‘, )) t.start() print("主線程")
方式二
from threading import Thread import time class Sayhi(Thread): def __init__(self, name): super().__init__() self.name = name def run(self): time.sleep(2) print(‘%s say hello‘ % self.name) if __name__ == ‘__main__‘: t = Sayhi(‘mike‘) t.start() print("主線程")
三 練習題
1、基於多線程實現並發的套接字通信
客戶端:
from socket import * ip = ‘127.0.0.1‘ port = 8081 c = socket(AF_INET, SOCK_STREAM) c.connect((ip, port)) while True: msg = input("請輸入客戶端的信息").strip() if not msg: continue c.send(msg.encode(‘utf-8‘)) data = c.recv(1024) print("收到的信息:", data.decode(‘utf-8‘))
服務端:
from socket import * from threading import Thread def talk(conn): while True: try: data = conn.recv(1204) if not data: break conn.send(data.upper()) except ConnectionResetError: break conn.close() def server(ip, port): server_socket = socket(AF_INET, SOCK_STREAM) server_socket.bind((ip, port)) server_socket.listen(1) while True: conn, addr = server_socket.accept() p = Thread(target=talk, args=(conn,)) p.start() conn.close() if __name__ == ‘__main__‘: server(‘127.0.0.1‘, 8081)
python並發編程:多線程-開啟線程的兩種方式