GeezerVisonThe World Wide Web, restored to 800 pixels of glory. |
| Home|About|Gaming cabinet|Archives|How it works|Starter sites |
GeezerVison is showing github.com — python-patterns/patterns/behavioral/publish_subscribe.py at master · dipanjanS/python-patterns Expand file tree/ Copy pathpublish_subscribe.pyMore file actions 92 lines (68 loc) · 1.97 KB / Copy pathpublish_subscribe.pyFile metadata and controls92 lines (68 loc) · 1.97 KB 1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 85 86 87 88 89 90 91 92 #!/usr/bin/env python # -*- coding: utf-8 -*- """ Reference: http://www.slideshare.net/ishraqabd/publish-subscribe-model-overview-13368808 Author: https://github.com/HanWenfang """ class Provider: def __init__(self): self.msg_queue = [] self.subscribers = {} def notify(self, msg): self.msg_queue.append(msg) def subscribe(self, msg, subscriber): self.subscribers.setdefault(msg, []).append(subscriber) def unsubscribe(self, msg, subscriber): self.subscribers[msg].remove(subscriber) def update(self): for msg in self.msg_queue: for sub in self.subscribers.get(msg, []): sub.run(msg) self.msg_queue = [] class Publisher: def __init__(self, msg_center): self.provider = msg_center def publish(self, msg): self.provider.notify(msg) class Subscriber: def __init__(self, name, msg_center): self.name = name self.provider = msg_center def subscribe(self, msg): self.provider.subscribe(msg, self) def unsubscribe(self, msg): self.provider.unsubscribe(msg, self) def run(self, msg): print("{} got {}".format(self.name, msg)) def main(): message_center = Provider() fftv = Publisher(message_center) jim = Subscriber("jim", message_center) jim.subscribe("cartoon") jack = Subscriber("jack", message_center) jack.subscribe("music") gee = Subscriber("gee", message_center) gee.subscribe("movie") vani = Subscriber("vani", message_center) vani.subscribe("movie") vani.unsubscribe("movie") fftv.publish("cartoon") fftv.publish("music") fftv.publish("ads") fftv.publish("movie") fftv.publish("cartoon") fftv.publish("cartoon") fftv.publish("movie") fftv.publish("blank") message_center.update() if __name__ == "__main__": main() OUTPUT = """ jim got cartoon jack got music gee got movie jim got cartoon jim got cartoon gee got movie """ |
| You are visitor 01402520 — GeezerVison does not store the pages you look up. Best viewed with Netscape Navigator 4.7 or Internet Explorer 6 at 800×600. No cookies required. |