Python中线程同步的实现

目录

• 多线程
• 案例
• 问题现象
• 解决办法
• 线程同步
• 线程等待
• 互斥锁

说明：

• 唱歌方法 sing()
• 跳舞方法 dance()
• 启用两个线程调用
• 主线程结束

代码

# 导入线程模块
import threading
import time


def sing(name,age):
    time.sleep(2)
    print('唱歌者姓名：' + name + '，年龄：' + str(age))
    print('正在唱歌...')


def dance(name, age):
    time.sleep(2)
    print('跳舞者姓名：' + name + '，年龄：' + str(age))
    print('正在跳舞...')


if __name__ == '__main__':
    # args 元组传参
    t1 = threading.Thread(target=sing,args=('Alice', 18))
    # kwargs 对象传参
    t2 = threading.Thread(target=dance,kwargs={'name': 'Bob', 'age': 18})
    t1.start()
    t2.start()
    print("主线程结束")

• 运行

• 输出的结果和代码的执行顺序不一致
• 最后的主线程输出竟然最先输出
• 线程的执行是异步的并非同步
• 那么如何让线程同步执行呢？请看下一章节 《解决办法》

• 线程等待
• 互斥锁

调用线程的等待方法： join()

• 代码

# 导入线程模块
from threading import Thread
import time


def sing(name,age):
    time.sleep(2)
    print('唱歌者姓名：' + name + '，年龄：' + str(age))
    print('正在唱歌...')


def dance(name, age):
    time.sleep(2)
    print('跳舞者姓名：' + name + '，年龄：' + str(age))
    print('正在跳舞...')


if __name__ == '__main__':
    # args 元组传参
    t1 = Thread(target=sing,args=('Alice', 18))
    # kwargs 对象传参
    t2 = Thread(target=dance,kwargs={'name': 'Bob', 'age': 18})
    t1.start()
    t1.join()
    t2.start()
    t2.join()
    print("主线程结束")

• 运行

步骤：

• 导入锁模块：from threading import Lock
• 实例化锁：lock = Lock()
• 获取锁：lock.acquire()
• 释放锁：lock.release()

代码

# 导入线程模块
from threading import Thread, Lock
import time


def sing(name, age):
    # 获取锁，用于线程同步
    lock.acquire()
    time.sleep(2)
    print('唱歌者姓名：' + name + '，年龄：' + str(age))
    print('正在唱歌...')
    # 释放锁，开启下一个线程
    lock.release()


def dance(name, age):
    # 获取锁，用于线程同步
    lock.acquire()
    time.sleep(2)
    print('跳舞者姓名：' + name + '，年龄：' + str(age))
    print('正在跳舞...')
    # 释放锁，开启下一个线程
    lock.release()


# 创建一个锁
lock = Lock()
if __name__ == '__main__':
    # args 元组传参
    t1 = Thread(target=sing, args=('Alice', 18))
    # kwargs 对象传参
    t2 = Thread(target=dance, kwargs={'name': 'Bob', 'age': 18})
    t1.start()
    # t1.join()
    t2.start()
    # t2.join()
    # print("主线程结束")

运行

到此这篇关于Python中线程同步的实现的文章就介绍到这了,更多相关Python 线程同步内容请搜索风君子博客以前的文章或继续浏览下面的相关文章希望大家以后多多支持风君子博客！

您可能感兴趣的文章:

• 深入解析Python中的线程同步方法
• Python实现的多线程同步与互斥锁功能示例
• Python编程scoketServer实现多线程同步实例代码
• Python线程同步的实现代码
• Python多线程同步—文件读写控制方法
• python多线程同步实例教程
• python多线程同步之文件读写控制
• Python的线程之线程同步
• Python中的线程同步的常用方法总结