Das deutsche Python-Forum

Code: Alles auswählen

from queue import Queue
import threading

class Eins(object):

    data = "eins"

    def __init__(self, q):
        self.q = q
        self.q.put(self.data)
        self.dataEins = self.q.get()
##        self.q.task_done()
        print(self.dataEins)
 
class Zwei(object):

    data = "zwei"
   
    def __init__(self, q):
        self.q = q
        self.dataZwei = self.q.get()
##        self.q.task_done()
        print(self.dataZwei)
        self.q.put(self.data)
        print("geschickt")
        
if __name__ == "__main__":

    q = Queue()

    eins = threading.Thread(target=Eins, args=(q,))
    zwei = threading.Thread(target=Zwei, args=(q,))

    eins.start()
    zwei.start()

Code: Alles auswählen

import time
from threading import Thread
from queue import Queue, Empty


def send(queue, message_nums=10):
    for n in range(message_nums):
        time.sleep(0.2)
        queue.put('message number: {}'.format(n))
        
        
def receive(queue):
    while True:
        try:
            message = queue.get(timeout=1)
        except Empty:
            break
        print(message)
    print('done.')
    

queue = Queue()
Thread(target=send, args=(queue,)).start()
Thread(target=receive, args=(queue,)).start()