python 并发编程之线程

from multiprocessing import Queue

if __name__ == '__main__':
    q = Queue(3)  # 队列的大小默认很大
    # 1. 如何入队、
    """obj, block=True, timeout=None"""
    q.put('hellowrold1')
    q.put('helloworld2')
    q.put('helloworld3')
    # q.put('helloworld4', block=False)  # 如果你知道了block参数，当队列满的时候，放不进去的时候，直接报错
    # q.put('helloworld4', timeout=3)  # 如果你知道了timeout参数，当往队列中放入数据的时候，等待3秒，如果放不进去，直接报错
    # q.put_nowait('helloworld4')  # 往队列中放入数据的时候，放不进去直接报错， 指定了参数:block=False

    # 2. 出队
    print(q.get())
    print(q.get())
    # print(q.get())
    """ block=True, timeout=None"""
    # print(q.get(block=False))
    # print(q.get(timeout=3))

    # print(q.get_nowait())  # 不等待取，取不到就报错
    print(q.qsize())  # 队列中剩余的数据量， 这个方法的结果有点不准确.
    # print(q.empty()) # 判断队列是否为空
    # print(q.full())  # 判断队列是否满了