python多任务——线程

太过爱你忘了你带给我的痛 2021-12-22 20:11 288阅读 0赞

# 1. #

并发：指的是任务数多余cpu核数，通过操作系统的各种任务调度算法，实现用多个任务“一起”执行（实际上总有一些任务不在执行，因为切换任务的速度相当快，看上去一起执行而已）  
并行：指的是任务数小于等于cpu核数，即任务真的是一起执行的

# 2 #

.线程  
python的thread模块是比较底层的模块，python的threading模块是对thread做了一些包装的，可以更加方便的被使用

# 3. #

多个线程执行，主线程等子线程结束后才结束运行

import threading
    from time import sleep,ctime
    
    def sing():
        for i in range(3):
            print("正在唱歌...%d"%i)
            sleep(1)
    
    def dance():
        for i in range(3):
            print("正在跳舞...%d"%i)
            sleep(1)
    
    if __name__ == '__main__':
        print('---开始---:%s'%ctime())
    
        t1 = threading.Thread(target=sing)
        t2 = threading.Thread(target=dance)
    
        t1.start()
        t2.start()
    
        #sleep(5) # 屏蔽此行代码，试试看，程序是否会立马结束？
        print('---结束---:%s'%ctime())

# 4. #

python的threading.Thread类有一个run方法，用于定义线程的功能函数，可以在自己的线程类中覆盖该方法。而创建自己的线程实例后，通过Thread类的start方法，可以启动该线程，交给python虚拟机进行调度，当该线程获得执行的机会时，就会调用run方法执行线程。

# 5. #

线程共享全局变量  
在一个进程内的所有线程共享全局变量，很方便在多个线程间共享数据  
缺点就是，线程是对全局变量随意遂改可能造成多线程之间对全局变量的混乱（即线程非安全）

# 6. #

创建互斥锁

# 创建锁
    mutex = threading.Lock()
    
    # 锁定
    mutex.acquire()
    
    # 释放
    mutex.release()

# 7. #

多任务udp案例

import socket
    import threading
    
    
    def send_msg(udp_socket):
        """获取键盘数据，并将其发送给对方"""
        while True:
            # 1. 从键盘输入数据
            msg = input("\n请输入要发送的数据:")
            # 2. 输入对方的ip地址
            dest_ip = input("\n请输入对方的ip地址:")
            # 3. 输入对方的port
            dest_port = int(input("\n请输入对方的port:"))
            # 4. 发送数据
            udp_socket.sendto(msg.encode("utf-8"), (dest_ip, dest_port))
    
    
    def recv_msg(udp_socket):
        """接收数据并显示"""
        while True:
            # 1. 接收数据
            recv_msg = udp_socket.recvfrom(1024)
            # 2. 解码
            recv_ip = recv_msg[1]
            recv_msg = recv_msg[0].decode("utf-8")
            # 3. 显示接收到的数据
            print(">>>%s:%s" % (str(recv_ip), recv_msg))
    
    
    def main():
        # 1. 创建套接字
        udp_socket = socket.socket(socket.AF_INET, socket.SOCK_DGRAM)
        # 2. 绑定本地信息
        udp_socket.bind(("", 7890))
    
        # 3. 创建一个子线程用来接收数据
        t = threading.Thread(target=recv_msg, args=(udp_socket,))
        t.start()
        # 4. 让主线程用来检测键盘数据并且发送
        send_msg(udp_socket)
    
    if __name__ == "__main__":
        main()