python 同步事件 event 简介

布满荆棘的人生 2021-09-02 04:17 409阅读 0赞

**目录**

1. Event

1.1 set()

1.2 wait()

1.3 clear()

1.4 is\_set()

2. 协调线程同步

3. 一个更复杂的例子

--------------------

事件 Event是另一种python多线程同步技术, 本文将使用python语言对这种技术进行讲解, 想象这样一个场景，你启动了多个线程，这些线程都要去访问一个资源，但是，这里有一个小小的问题，即将被访问的资源还没有准备好接受访问，那么此时，多个线程去访问，必然得到不响应，你还得处理这种得不到响应的情况

*  [python多线程同步---事件 Event][python_---_ Event]
    
     *  [1. Event][]
        
         *  [1.1 set()][1.1 set]
         *  [1.2 wait()][1.2 wait]
         *  [1.3 clear()][1.3 clear]
         *  [1.4 is\_set()][1.4 is_set]
     *  [2. 协调线程同步][2.]
     *  [3. 一个更复杂的例子][3.]

## 1. Event ##

借助Event，可以灵活的协调线程间的操作，它提供了下面几个方法

### 1.1 set() ###

将事件内部标识设置为True，Event对象最初创建时，内部标识默认是False

### 1.2 wait() ###

当在线程中调用wait时，如果事件内部标识为False，则会阻塞，直到set方法被调用，将内部标识设置为True

### 1.3 clear() ###

将内部标识重新设置为False

### 1.4 is\_set() ###

如果内部标识是True，则返回True，反之，返回False

## 2. 协调线程同步 ##

想象这样一个场景，你启动了多个线程，这些线程都要去访问一个资源，但是，这里有一个小小的问题，即将被访问的资源还没有准备好接受访问，那么此时，多个线程去访问，必然得到不响应，你还得处理这种得不到响应的情况。

这样的场景下，能否先在主线程里去做试探，确定资源可以访问以后，再让已经启动了的多线程去访问呢？让我们考虑一下如何用Event来处理这样的问题

1.  创建一个Event对象，现在，事件内部标识是False
2.  启动多线程，线程里调用wait方法，这时，会阻塞
3.  主线程去试探，确定资源可访问以后，调用set方法
4.  已经调用wait的线程接手到事件信息，访问资源

以下为示例代码

import threading
    from threading import Event
    
    
    def worker(event_obj, i):
        print('{i}号线程等待事件信号'.format(i=i))
        event_obj.wait()
        print('{i}号线程收到事件信号'.format(i=i))
    
    
    event = Event()
    
    for i in range(5):
        t = threading.Thread(target=worker, args=(event, i))
        t.start()
    
    print('确认资源可用')
    event.set()

## 3. 一个更复杂的例子 ##

一个线程依次打印1 3 5 ，一个线程依次打印 2 4 6，使用事件做消息同步，使得两个线程启动后，打印出1 2 3 4 5 6, 别看要求很简单，但实现起来却是有难度的，每个线程输出不同的数列，但整体上看却要求有序。

针对这样的线程同步要求，可以创建两个Event对象，两个线程互相触发另一个线程的Event对象

import threading
    from threading import Event
    
    
    def print_a(e1, e2):
        for item in [1, 3, 5]:
            e1.wait()
            print(item)
            e1.clear()
            e2.set()
    
    
    def print_b(e1, e2):
        for item in [2, 4, 6]:
            e1.wait()
            print(item)
            e1.clear()
            e2.set()
    
    e1, e2 = Event(), Event()
    t1 = threading.Thread(target=print_a, args=(e1, e2))
    t2 = threading.Thread(target=print_b, args=(e2, e1))
    t1.start()
    t2.start()
    e1.set()

[python_---_ Event]: http://coolpython.net/python_senior/concurrent/multithreading_event.html#toc_0
[1. Event]: http://coolpython.net/python_senior/concurrent/multithreading_event.html#toc_1
[1.1 set]: http://coolpython.net/python_senior/concurrent/multithreading_event.html#toc_2
[1.2 wait]: http://coolpython.net/python_senior/concurrent/multithreading_event.html#toc_3
[1.3 clear]: http://coolpython.net/python_senior/concurrent/multithreading_event.html#toc_4
[1.4 is_set]: http://coolpython.net/python_senior/concurrent/multithreading_event.html#toc_5
[2.]: http://coolpython.net/python_senior/concurrent/multithreading_event.html#toc_6
[3.]: http://coolpython.net/python_senior/concurrent/multithreading_event.html#toc_7