python queue.join()的问题

Question

尝试利用python中的queue中join方法，创建两个线程，在一个线程中的阻塞消息队列，尝试在另外一个线程中，解除阻塞状态，但是好像无效

import queue
import threading

q = queue.Queue(maxsize=3)

def 消费阻塞():
    for i in range(3):
        try:
            q.put_nowait('任务' + str(i+1))
        except queue.Full:
            print('full')

    for i in range(2):
        try:
            task = q.get(block=True, timeout=3)
            print(task)
            q.task_done()
        except queue.Empty:
            print('队列为空，get失败')
    # # 阻塞队列
    # if q.qsize()==2:
    print(q.qsize())
    q.join()
    print('Finished')

def consumer():
    while q.qsize!=0:
        print(q.get(),1)
        q.task_done()
    

if __name__ == '__main__':
    A=threading.Thread(target=消费阻塞())
    B=threading.Thread(target=consumer())
    A.start()
    B.start()

(运行结果及报错内容 https://img-mid.csdnimg.cn/release/static/image/mid/ask/627988689146125.PNG ")

猜想是否是task_down()未加入的问题，但是好像加入后无用

期望正常结束程序

Answer 1

threading.Thread的target参数要传递函数的引用地址,函数名后面不要加括号

A=threading.Thread(target=消费阻塞())
B=threading.Thread(target=consumer())

改成

A=threading.Thread(target=消费阻塞)
B=threading.Thread(target=consumer)

函数名后面加括号是直接调用函数,不会在新的一个线程中执行