1、
# coding : UTF-8
import threading, time     # 导入相关模块
class Message: # 数据描述类型
    def __init__(self): # 构造方法
        self.__title = None # 初始化属性
        self.__content = None # 初始化属性
    def set_info(self, title, content): # 进行属性内容设置
        self.__title = title # 设置属性内容
        time.sleep(1) # 进行操作的生产延迟
        self.__content = content # 设置属性内容
        print(“【%s】title = %s、content = %s” % (threading.current_thread().name, self.__title, self.__content))
    def __str__(self): # 获取数据将由消费者负责
        time.sleep(0.8) # 消费者延迟时间
        return “〖%s〗title = %s、content = %s” % (threading.current_thread().name, self.__title, self.__content)
def producer_handle(message): # 生产者处理函数
    for num in range(50): # 生产50组数据
        if num % 2 == 0 : # 交替生产
            message.set_info(“李兴华”, “软件技术讲师”)
        else:
            message.set_info(“yootk“, “www.yootk.com“)
def consumer_handle(message): # 消费者处理函数
    for num in range(50):
        print(message) # 获取50次的数据
def main(): # 主函数
    message = Message() # 公共保存数据对象
    producer_thread = threading.Thread(target=producer_handle, name=”生产者线程“, args=(message,))
    consumer_thread = threading.Thread(target=consumer_handle, name=”消费者线程“, args=(message,))
    producer_thread.start() # 启动线程
    consumer_thread.start() # 启动线程
if __name__ == “__main__”: # 判断程序执行名称
    main() # 调用主函数

2、
# coding : UTF-8
import threading, time     # 导入相关模块
class Message: # 数据描述类型
    def __init__(self, condition): # 构造方法
        self.__title = None # 初始化属性
        self.__content = None # 初始化属性
        self.__condition = condition # 获取同步
        # flag = True表示可以生产,但是不能够消费
        # flag = False表示可以消费,但是不能够生产
        self.__flag = True
    def set_info(self, title, content): # 进行属性内容设置
        self.__condition.acquire() # 获取同步
        if self.__flag == False: # 不能够继续生产了,必须进行消费处理
            self.__condition.wait() # 当前的线程进入阻塞状态
        # 如果现在可以生产则一定会执行如下的代码操作,进行数据的设置,同时修改flag标志(此时的flag = True)
        self.__title = title # 设置属性内容
        time.sleep(1) # 进行操作的生产延迟
        self.__content = content # 设置属性内容
        print(“【%s】title = %s、content = %s” % (threading.current_thread().name, self.__title, self.__content))
        self.__flag = False # 现在已经生产过了
        self.__condition.notify() # 唤醒其他等待的线程
        self.__condition.release() # 释放锁
    def __str__(self): # 获取数据将由消费者负责
        self.__condition.acquire() # 获取
        if self.__flag == True: # 不是消费状态
            self.__condition.wait() # 等待生产者生产数据
        # 如果执行了如下的代码,则意味着不进行等待(flag = False)
        try:
            time.sleep(0.8) # 消费者的延迟时间
            return “〖%s〗title = %s、content = %s” % (threading.current_thread().name, self.__title, self.__content)
        finally:
            self.__flag = True # 可以继续生产, 无法消费了
            self.__condition.notify()  # 唤醒其他等待的线程
            self.__condition.release()  # 释放锁
def producer_handle(message): # 生产者处理函数
    for num in range(50): # 生产50组数据
        if num % 2 == 0 : # 交替生产
            message.set_info(“李”, “软件技术讲师”)
        else:
            message.set_info(“yootk”, “www.com“)
def consumer_handle(message): # 消费者处理函数
    for num in range(50):
        print(message) # 获取50次的数据
def main(): # 主函数
    condition = threading.Condition() # 实例条件
    message = Message(condition) # 公共保存的数据对象
    producer_thread = threading.Thread(target=producer_handle, name=”生产者线程”, args=(message,))
    consumer_thread = threading.Thread(target=consumer_handle, name=”消费者线程”, args=(message,))
    producer_thread.start() # 启动线程
    consumer_thread.start() # 启动线程
if __name__ == “__main__”: # 判断程序执行名称
    main() # 调用主函数

3、

# coding : UTF-8
import threading, time, queue     # 导入相关模块
class Message: # 数据的描述类型
    def __init__(self): # 构造方法
        self.__title = None # 初始化属性
        self.__content = None # 初始化属性
    def set_info(self, title, content): # 进行属性内容的设置
        self.__title = title # 设置属性内容
        time.sleep(0.1) # 进行操作的生产延迟
        self.__content = content # 设置属性内容
        print(“【%s】title = %s、content = %s” % (threading.current_thread().name, self.__title, self.__content))
    def __str__(self): # 获取数据将由消费者负责
        time.sleep(0.8) # 消费者的延迟时间
        return “〖%s〗title = %s、content = %s” % (threading.current_thread().name, self.__title, self.__content)
def producer_handle(worker_queue): # 生产者处理函数
    for num in range(50): # 生产50组数据
        message = Message() # 定义生产数据的包装类型
        if num % 2 == 0 : # 交替生产
            message.set_info(“李兴华”, “软件技术讲师”)
        else:
            message.set_info(“ww”, “www.com“)
        worker_queue.put(message) # 将生产后的数据放到队列之中
def consumer_handle(worker_queue): # 消费者处理函数
    for num in range(50):
        print(worker_queue.get()) # 通过队列获取数据
def main(): # 主函数
    worker_queue = queue.Queue(5) # 定义一个5个大小队列
    producer_thread = threading.Thread(target=producer_handle, name=”生产者线程”, args=(worker_queue,))
    consumer_thread = threading.Thread(target=consumer_handle, name=”消费者线程”, args=(worker_queue,))
    producer_thread.start() # 启动线程
    consumer_thread.start() # 启动线程
if __name__ == “__main__”: # 判断程序执行名称
    main() # 调用主函数

原文地址:https://blog.csdn.net/softshow1026/article/details/134687672

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任

如若转载,请注明出处:http://www.7code.cn/show_14243.html

如若内容造成侵权/违法违规/事实不符,请联系代码007邮箱:suwngjj01@126.com进行投诉反馈,一经查实,立即删除

发表回复

您的邮箱地址不会被公开。 必填项已用 * 标注