функция dequeue в питоне

Question

Я использую темы.Один поток как поток производителя, а другой поток как поток потребителя.Потоки ставят в очередь и удаляют из одной и той же очереди (q1).Функция продюсера работает нормально.Однако потребительский поток (функция dequeue) выдает мне ошибку.Ниже мой код

def PacketProducer(Threadnum, numTicks, onProb, offProb, q):
   l=0
   onState = True
   packetId = 0
   for i in range(numTicks):
      x = generator(onProb, offProb, 'OnOff', onState)
      if(x==True):
            onState = True
            pkt = packet
            pkt.srcID = Threadnum
            pkt.pktId = packetId
            q.put(pkt)
            print(pkt.pktId, ' ', pkt.srcID)
            l = l+1
            packetId = packetId + 1
        else:
            onState = False
        time.sleep(1)
    #print(x)
    print(l/numTicks, ' threadNum', Threadnum)
    return

def PacketConsumer(q):  #dequeues and enqueues and returns the packet
    while True:
        if not q.empty():
            pkt = q.get()
            print('dequeuing Packet', ' ', pkt.pktId, pkt.srcID)
            time.sleep(1)
    return
if __name__ == '__main__':
    numTicks = 40
    q1 = Queue()
    pkt = packet
    x = threading.Thread(target=PacketProducer, args=(1, numTicks, 0.7, 0.7, q1))
    #y = threading.Thread(target=PacketProducer, args=(2, numTicks, 0.6, 0.4, q1))
    t = threading.Thread(target=PacketConsumer, args=(q1))
    t.start()
    x.start()
    #y.start()
    x.join()
#    y.join()
    t.join()

Это дает мне следующую ошибку:

Exception in thread Thread-2:
Traceback (most recent call last):
  File "C:\Users\Syed\AppData\Local\Programs\Python\Python37-32\lib\threading.py", line 917, in _bootstrap_inner
    self.run()
  File "C:\Users\Syed\AppData\Local\Programs\Python\Python37-32\lib\threading.py", line 865, in run
    self._target(*self._args, **self._kwargs)
TypeError: PacketConsumer() argument after * must be an iterable, not Queue

Answer 1

В кортеже одного элемента должно быть ,, чтобы различать его как таковое, в противном случае это просто группировка скобок.

Измените эту строку:

t = threading.Thread(target=PacketConsumer, args=(q1,))