Python Message Queue

[PyGast]

Hallo,

kennt jemand ein Message Queue System für Python?


Vielen Dank
Gruss

[rayo]

Hi

Öhm und was soll das Darstellen?

Meinst du das modul Queue?

Gruss

[Gast]

hmm.. was macht das queue modul? meinst du die liste?

Ich brauche ein message queue system um zwischen mehreren modulen kommunizieren zu können, ohne dass diese einander kennen. Client / Server Prinzip...

[rayo]

Ja dafür gibts die Doku. Da steht es wunderbar drin, was das Queue module macht.

Ich denke du suchst genau dieses Modul. Die Queue ist eine FIFO-Liste (First-In First-Out) und dazu auch noch thread-safe (kannst von verschiedenen Threads ohne Probleme darauf zugreifen).

Code: Alles auswählen

import thread
from Queue import Queue

def waiter(q):
    while 1:
        item = q.get()
        print 'waiter got item:',item, type(item)

itemqueue = Queue()
thread.start_new_thread(waiter, (itemqueue,))

itemqueue.put('hallo')
itemqueue.put([1,'test'])
itemqueue.put(waiter)

Gruss