【python】多任务(1. 线程)
程序员文章站
2022-05-22 17:02:02
线程执行的顺序是不确定,可以通过适当的延时,保证某一线程先执行 基础语法 比较复杂的过程,通过类继承Thread类完成创建线程 多线程全局变量的共享 在一个函数中对全局变量进行修改的时候,到底是否需要使用global进行说明要看是否对全局变量的执行指向进行了修改, 如果修改了执行,即让全局变量指向了 ......
线程执行的顺序是不确定,可以通过适当的延时,保证某一线程先执行
基础语法
# 多线程的使用方式 import threading def test1():... # 如果创建thread时执行的函数,运行结束,那么意味着,这个子线程结束了 def test2():... def main(): t1 = threading.thread(target=test1) t2 = threading.thread(target=test2) t1.start() t2.start() print(threading.enumerate()) if __name__ == '__main__': main()
比较复杂的过程,通过类继承thread类完成创建线程
import threading import time class mythread(threading.thread): def fun(self): for i in range(5): time.sleep(1) print("[%s]" % i) if __name__ == '__main__': t = mythread() t.start() # start() 调用 self.run() , 涉及调用其它方法,到run函数中调用
多线程全局变量的共享
在一个函数中对全局变量进行修改的时候,到底是否需要使用global进行说明要看是否对全局变量的执行指向进行了修改,
如果修改了执行,即让全局变量指向了一个新的地方,那么必须使用global
如果,仅仅是修改了指向的空间中的数据,此时不必使用global
# 无参 import threading import time g_num = 100 def test1(): global g_num g_num += 1 print("--------in test1 g_num=%d--------" % g_num) def test2(): print("--------in test2 g_num=%d--------" % g_num) def main(): t1 = threading.thread(target=test1) t2 = threading.thread(target=test2) t1.start() time.sleep(1) t2.start() time.sleep(1) print("--------in main g_num=%d--------" % g_num) if __name__ == '__main__': main() # 带参 import threading import time g_num = 100 def test1(temp): temp.append(33) print("--------in test1 g_nums=%s--------" % str(temp)) def test2(temp): print("--------in test2 g_nums=%s--------" % str(temp)) g_nums = [11,22] def main(): # target 去哪个函数执行代码 # args 带着什么过去的 t1 = threading.thread(target=test1, args=(g_nums,)) t2 = threading.thread(target=test2, args=(g_nums,)) t1.start() time.sleep(1) t2.start() time.sleep(1) print("--------in main g_nums=%s--------" % str(g_nums)) if __name__ == '__main__': main()
多线程任务的资源竞争
import threading import time g_num = 0 def test1(num): global g_num for i in range(num): g_num += 1 print("----in test1 g_num=%d----" % g_num) def test2(num): global g_num for i in range(num): g_num += 1 print("----in test2 g_num=%d----" % g_num) def main(): t1 = threading.thread(target=test1, args=(1000000,)) t2 = threading.thread(target=test2, args=(1000000,)) t1.start() t2.start() time.sleep(5) print("----in main gnum=%d----" % g_num) if __name__ == '__main__': main() """ ----in test1 g_num=1188472---- ----in test2 g_num=1319841---- ----in main g_num=1319841---- """
互斥锁,避免资源竞争
import threading import time g_num = 0 def test1(num): global g_num # 上锁,如果之前没有被上锁,那么此时,上锁成功 # 如果上锁之前,已经被上锁了,那么此时会阻塞在这里,直到这个锁被解开为止 mutex1.acquire() for i in range(num): g_num += 1 mutex1.release() print("----in test1 g_num=%d----" % g_num) def test2(num): global g_num mutex1.acquire() for i in range(num): g_num += 1 mutex1.release() print("----in test2 g_num=%d----" % g_num) mutex1 = threading.lock() def main(): t1 = threading.thread(target=test1, args=(1000000,)) t2 = threading.thread(target=test2, args=(1000000,)) t1.start() t2.start() time.sleep(1) print("----in main gnum=%d----" % g_num) if __name__ == '__main__': main()
多线程版udp聊天器
import socket import threading # 接收数据 def recv_msg(udp_socket): while true: recv_data,data_from = udp_socket.recvfrom(1024) print("来自%s: [%s] " % (data_from, recv_data.decode('gbk'))) # 接收数据 def send_msg(udp_socket): while true: send_data = input("输入要发送的数据:") udp_socket.sendto(send_data.encode('gbk'),("192.168.2.193", 8080)) def main(): udp_socket = socket.socket(socket.af_inet,socket.sock_dgram) # 2. 绑定本地信息 udp_socket.bind(("", 7890)) # 对方的连接信息,用的固定值,没有用变量传递 # 创建两个线程 t_recv = threading.thread( target=recv_msg, args=(udp_socket,)) t_send = threading.thread( target=send_msg, args=(udp_socket,)) t_recv.start() t_send.start() if __name__ == '__main__': main()
上一篇: C基本语法