11.python并发入门(part5 event对象)

一、引入event。

每个线程,都是一个独立运行的个体,并且每个线程的运行状态是无法预测的。

如果一个程序中有很多个线程,程序的其他线程需要判断某个线程的运行状态,来确定自己下一步要执行哪些操作。

threading模块中的event对象恰好能做到这一点,event对象包含了一个可以通过线程设置的一个信号标志位,它允许线程一直等待某些事件的发生。

在初始化默认的情况下,event对象中的信号标识被设置为“假”,如果这时,有一个线程等待这个event对象,而这个event对象的信号标志为“假”,那么这个线程就会被一直阻塞下去,直到这个event信号标志为“真”,所有等待这个event对象的线程才会被唤醒。

也就是说,一个线程如果等待的event对象中的信号标志位“真”,这个线程会忽略这个事件(event),继续执行。


二、event对象的常用方法。

event.isSet():返回event的状态值。

event.wait(): 当event对象内部的信号标识设置为“假”(False),所有等待这个event对象的线程将会全部被阻塞。


event.set():设置event对象内部的信号标识为“真”(True),所有等待这个event对象的线程将会被唤醒,等待操作系统的调度。


event.clear():恢复event的状态值为False。


下面这个图,能让你清楚的明白event.wait和event.set之间的关系:


三、event使用示例。

我们来考虑下event对象的应用场景。

假如,在一个程序中,有多个线程需要到redis中来取数据,每个线程都要去尝试着去连接redis服务器,一般情况下,redis如果连接不成功,在所有线程中都需要尝试着去重新连接。

如果我们想要在程序启动时,先要确保redis服务器工作正常,接着在让其他工作的线程去连接redis服务器,当遇到这种需求的时候,使用event对象就是一个非常不错的选择。

我们可以使用event机制去让各个工作的线程去做一个简单的通信,主线程去连接redis服务器,如果连接到了,event对象内的信号标识改为真,其余工作的线程就会被唤醒。


示例:

#!/usr/local/bin/python2.7

# -*- coding:utf-8 -*-

import threading

import time

import logging

logging.basicConfig(level=logging.DEBUG, format='(%(threadName)-10s) %(message)s',)

def worker(event):

    logging.debug("waiting for redis ready....")

    event.wait()

    logging.debug("redis ready,and connect to redis server and do some work %s",time.ctime())

    time.sleep(1)

def main():

    redis_ready = threading.Event()

    t1 = threading.Thread(target=worker,args=(redis_ready,),name="threading-1")

    t1.start()

    t2 = threading.Thread(target=worker,args=(redis_ready,),name="threading-2")

    t2.start()

    logging.debug("first of all,check redis server, make sure it is ok , and then trigger the redis ready event")

    time.sleep(3)

    redis_ready.set()

if __name__ == '__main__':

    main()


输出结果:

(threading-1) waiting for redis ready....

(threading-2) waiting for redis ready....

(MainThread) first of all,check redis server, make sure it is ok , and then trigger the redis ready event

(threading-1) redis ready,and connect to redis server and do some work Sun May 14 09:35:46 2017

(threading-2) redis ready,and connect to redis server and do some work Sun May 14 09:35:46 2017


代码分析:

在上面这段代码中,一共开了三个线程,分别是threading-1和threading-2还有主线程,首先主线程运行了main()函数,产生了一个event对象,这个event对象信号的初始值是False,然后创建了threading-1和threading-2两个线程并且运行,输出一条日志first of all,check redis server, make sure it is ok , and then trigger the redis ready event后sleep 3秒,此时切换到了threading-1,threading-1首先执行了worker函数,输出一次日志,然后执行event.wait方法,当这个event对象的信号标识为False时,threading-1就被阻塞住了,暂时无法执行woker函数后面的内容,当threading-1被阻塞住后,随即切换到threading-2(为什么一定切换到threading-2呢?这是因为主线程还在sleep),threading-2此时也去执行woker函数,同样先输出一条日志waiting for redis ready....,当执行到event.wait时,这个event对象的信号标志位依旧为False,所以执行到这里的时候,threading-2也会被阻塞。

过了3秒后,MainThread主线程sleep结束,开始向下运行,执行了redis_ready.set()后,我们创建的那个名为redis_ready的event对象中的信号标志会变为True,当这event对象的信号标志变为True之后,之前阻塞的threading-1和threading-2都会被唤醒,继续执行woker函数后面的代码。

(threading-1) redis ready,and connect to redis server and do some work Sun May 14 09:35:46 2017

(threading-2) redis ready,and connect to redis server and do some work Sun May 14 09:35:46 2017


四、event对象的补充。

threading.Event的wait方法还接受一个超时参数,默认情况下如果事件一致没有发生,wait方法会一直阻塞下去,而加入这个超时参数之后,如果阻塞时间超过这个参数设定的值之后,wait方法会返回。对应于上面的应用场景,如果Redis服务器一致没有启动,我们希望子线程能够打印一些日志来不断地提醒我们当前没有一个可以连接的Redis服务,我们就可以通过设置这个超时参数来达成这样的目的:


def worker(event):

    while not event.is_set():

        logging.debug('Waiting for redis ready...')

        event.wait(2)

    logging.debug('redis ready, and connect to redis server and do some work [%s]', time.ctime())

    time.sleep(1)





本文转自苏浩智 51CTO博客,原文链接:http://blog.51cto.com/suhaozhi/1925428,如需转载请自行联系原作者


本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.mzph.cn/news/540191.shtml

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

[转载] Java 将字符串首字母转为大写 - 利用ASCII码偏移

参考链接: 使用ASCII值检查Java中的字符串是否仅包含字母 将字符串name 转化为首字母大写。普遍的做法是用subString()取第一个字母转成大写再与之后的拼接: str str.substring(0, 1).toUpperCase() str.substring(1); 看到一种效率更高的做法&…

俞永福卸任阿里大文娱董事长,改任 eWTP 投资组长

两天前(11月13日),阿里文娱董事长俞永福离职的消息,在互联网圈炸了锅。但很快,俞本人就在微博做了澄清,并称“永远幸福,我不会离开”。然而就在今天(11月15日)&#xff0…

[转载] java提取字符串中的字母数字

参考链接&#xff1a; 使用Regex检查字符串在Java中是否仅包含字母 String str "adsf adS DFASFSADF阿德斯防守对方asdfsadf37《&#xff1f;&#xff1a;&#xff1f;%#&#xffe5;%#&#xffe5;%#$%#$%^><?1234"; str str.replaceAll("[^a-zA-…

snort的详细配置

前一段一直在做snort入侵检测系统的安装以及配置&#xff0c;看了很多的网上资料&#xff0c;也算是总结了下前辈的经验吧。需要的软件包&#xff1a;1、httpd-2.2.6.tar.gz2、mysql-5.1.22-rc-linux-i686-icc-glibc23.tar.gz3、php-5.2.4.tar.bz24、acid-0.9.6b23.tar.gz5、ad…

[转载] Java:获取数组中的子数组的多种方法

参考链接&#xff1a; Java中的数组Array 我的个人博客&#xff1a;zhang0peter的个人博客 Java&#xff1a;从一个数组中创建子数组 使用Arrays.copyOfRange函数 Arrays.copyOfRange支持&#xff1a;boolean[]&#xff0c; byte[] &#xff0c;char[]&#xff0c;double…

[转载] Java中Array(数组)转List(集合类)的几种方法

参考链接&#xff1a; Java中的数组类Array 1、循环。新建List类&#xff0c;循环填充。 2、利用Arrays类的静态方法asList()。 Arrays.asList(T[])返回Arrays类的一个内部内List(T)&#xff0c;此类继承自AbstractList&#xff0c;不可增删。若想要一个可以增删的List类&am…

Linux查看系统cpu个数、核心书、线程数

Linux查看系统cpu个数、核心书、线程数 现在cpu核心数、线程数越来越高&#xff0c;本文将带你了解如何确定一台服务器有多少个cpu、每个cpu有几个核心、每个核心有几个线程。 查看物理cpu个数 cat /proc/cpuinfo |grep "physical id"|sort |uniq|wc -l 查看核…

[转载] java中数组的反射的探究

参考链接&#xff1a; Java中的反射数组类reflect.Array 数组的反射有什么用呢&#xff1f;何时需要使用数组的反射呢&#xff1f;先来看下下面的代码&#xff1a; Integer[] nums {1, 2, 3, 4}; Object[] objs nums; //这里能自动的将Integer[]转成Object[] Object obj n…

防火墙iptables之常用脚本

防火墙iptables之常用脚本 转自&#xff1a;http://zhujiangtao.blog.51cto.com/6387416/1286490 标签&#xff1a;防火墙 主机 1。不允许别人ping我的主机&#xff0c;但是我可以ping别人的主机 #!/bin/bash iptables -F iptables -X iptables -Z modprobe ip_tables modprobe…

[转载] java中50个关键字以及各自用法大全

参考链接&#xff1a; Java中的默认数组值 关键字和保留字的区别 正确识别java语言的关键字&#xff08;keyword&#xff09;和保留字&#xff08;reserved word&#xff09;是十分重要的。Java的关键字对java的编译器有特殊的意义&#xff0c;他们用来表示一种数据类型&…

NFS 共享存储

服务器客户端yum -y install rpcbind nfs-utils 服务器 vim /etc/exports /data 192.168.10.0/24(rw,sync,no_root_squash) * ro # 只读权限 * rw # 读写权限 * sync # 同步&#xff0c;数据更安全&#xff0c;速度慢 * async #异步&#xff0c;速度快&#xff0c;效率高&a…

[转载] Java中的final变量、final方法和final类

参考链接&#xff1a; Java中的final数组 &#xff5c; Final arrays 1、final变量 final关键字可用于变量声明&#xff0c;一旦该变量被设定&#xff0c;就不可以再改变该变量的值。通常&#xff0c;由final定义的变量为常量。例如&#xff0c;在类中定义PI值&#xff0c;可…

Linux基础篇_01_计算机概论

学习资料&#xff1a;《鸟哥的Linux私房菜&#xff08;基础篇&#xff09;》部分&#xff1a;Linux的规划与安装 时间&#xff1a;20130225 学习笔记&#xff1a;计算机定义&#xff1a;接受使用者输入指令与数据&#xff0c; 经由中央处理器的数学与逻辑单元运算处理后&#x…

[转载] java中的经典问题:传值与传引用

参考链接&#xff1a; 有关Java中数组分配的有趣事实 参数传递的秘密 知道方法参数如何传递吗&#xff1f; 记得刚开始学编程那会儿&#xff0c;老师教导&#xff0c;所谓参数&#xff0c;有形式参数和实际参数之分&#xff0c;参数列表中写的那些东西都叫形式参数&#x…

[3/21]Windows Server 2008时钟方面的改进展示

在Windows Server 2008中的时钟显示和以往Windows Server 2003及以前的版本显示有很大的差别。如果要显示并进行简单的时间修改可以在时钟上双击&#xff0c;会出现如下图所示的界面。在上图中可以调整但无法进行真正的修改&#xff0c;彻底修改需要点击&#xff02;更改日期和…

[转载] 黑马程序员_学习笔记8_C#基础归纳之数组

参考链接&#xff1a; Java中的锯齿数组Jagged array ---------------------- Windows Phone 7手机开发、.Net培训、期待与您交流&#xff01; ---------------------- 什么是数组&#xff1f; 数组是一组数据结构&#xff0c;它可以包含同一类型的多个元素。C#用特殊记号还…

2Python全栈之路系列之MysQl基本数据类型

Python全栈之路系列之MySQL基本数据类型 MySQL中定义数据字段的类型对你数据库的优化是非常重要的。 MySQL支持多种类型&#xff0c;大致可以分为三类&#xff1a; 数字类型 日期和时间类型 字符串类型 数字类型 类型大小用途BIT-二进制TINYINT1字节小整数值INT or INTEGER4字…

[转载] JAVA笔记_(Day04,Day05)函数数组

参考链接&#xff1a; 了解Java中的数组IndexOutofbounds异常 文章目录 函数定义练习误区重载&#xff08;overload&#xff09;重载选择题练习函数的内存调用问题 数组定义数组的内存图解数组的常见问题应用求和最大值将数组转成字符串查表法转十六进制查表版&#xff08;十六…

VDI序曲二 RemotoAPP部署

首先&#xff0c;我们需要准备如下角色&#xff1a;沿用VDI序曲一的2台物理服务器以及角色我们在物理服务器1的hyper-v上&#xff0c;我们利用之前我介绍的“服务器虚拟化之准备母盘VHD”的方法再创建如下虚拟机&#xff1a;WIN-RDAPP&#xff1b;WIN-RDWA&#xff1b;WIN-RDCB…

[转载] Java ArrayList toArray(T[] a) 解惑

参考链接&#xff1a; Java中的Array vs ArrayList 先看一个小的代码片段 ArrayList<Integer> arrayList new ArrayList<>(); Collections.addAll(arrayList, 11, 21, 31, 41, 51); Integer[] a new Integer[0]; Integer[] b new Integer[arrayList.size()]; …