{"id":1287,"date":"2018-05-25T19:55:41","date_gmt":"2018-05-25T11:55:41","guid":{"rendered":"https:\/\/damogame.cn:15443\/wordpress\/?p=1287"},"modified":"2018-05-25T19:55:41","modified_gmt":"2018-05-25T11:55:41","slug":"python-%e6%a8%a1%e6%8b%9f%e4%ba%8b%e4%bb%b6%e8%a7%a6%e5%8f%91%e6%9c%ba%e5%88%b6","status":"publish","type":"post","link":"https:\/\/i007.cc\/wordpress\/archives\/1287","title":{"rendered":"python \u6a21\u62df\u4e8b\u4ef6\u89e6\u53d1\u673a\u5236"},"content":{"rendered":"

python \u6a21\u62df\u4e8b\u4ef6\u89e6\u53d1\u673a\u5236<\/a><\/h1>\n
<\/div>\n
\n
\n

EventManager.py<\/p>\n

\n
\"\u590d\u5236\u4ee3\u7801\"<\/a><\/span><\/div>\n
 1 # -*- encoding: UTF-8 -*-\r\n 2 \r\n 3 # \u7cfb\u7edf\u6a21\u5757\r\n 4 from queue import Queue, Empty\r\n 5 from threading import *\r\n 6 \r\n 7 \r\n 8 class EventManager:\r\n 9     def __init__(self):\r\n10         \"\"\"\u521d\u59cb\u5316\u4e8b\u4ef6\u7ba1\u7406\u5668\"\"\"\r\n11         # \u4e8b\u4ef6\u5bf9\u8c61\u5217\u8868\r\n12         self.__eventQueue = Queue()\r\n13         # \u4e8b\u4ef6\u7ba1\u7406\u5668\u5f00\u5173\r\n14         self.__active = False\r\n15         # \u4e8b\u4ef6\u5904\u7406\u7ebf\u7a0b\r\n16         self.__thread = Thread(target = self.__Run)\r\n17 \r\n18         # \u8fd9\u91cc\u7684__handlers\u662f\u4e00\u4e2a\u5b57\u5178\uff0c\u7528\u6765\u4fdd\u5b58\u5bf9\u5e94\u7684\u4e8b\u4ef6\u7684\u54cd\u5e94\u51fd\u6570\r\n19         # \u5176\u4e2d\u6bcf\u4e2a\u952e\u5bf9\u5e94\u7684\u503c\u662f\u4e00\u4e2a\u5217\u8868\uff0c\u5217\u8868\u4e2d\u4fdd\u5b58\u4e86\u5bf9\u8be5\u4e8b\u4ef6\u76d1\u542c\u7684\u54cd\u5e94\u51fd\u6570\uff0c\u4e00\u5bf9\u591a\r\n20         self.__handlers = {}   # {\u4e8b\u4ef6\u7c7b\u578b:[\u5904\u7406\u4e8b\u4ef6\u7684\u65b9\u6cd5]}\r\n21 \r\n22     def __Run(self):\r\n23         \"\"\"\u5f15\u64ce\u8fd0\u884c\"\"\"\r\n24         while self.__active == True:\r\n25             try:\r\n26                 # \u83b7\u53d6\u4e8b\u4ef6\u7684\u963b\u585e\u65f6\u95f4\u8bbe\u4e3a1\u79d2\r\n27                 event = self.__eventQueue.get(block = True, timeout = 1)  \r\n28                 self.__EventProcess(event)\r\n29             except Empty:\r\n30                 pass\r\n31 \r\n32     def __EventProcess(self, event):\r\n33         \"\"\"\u5904\u7406\u4e8b\u4ef6\"\"\"\r\n34         # \u68c0\u67e5\u662f\u5426\u5b58\u5728\u5bf9\u8be5\u4e8b\u4ef6\u8fdb\u884c\u76d1\u542c\u7684\u5904\u7406\u51fd\u6570\r\n35         if event.type_ in self.__handlers:\r\n36             # \u82e5\u5b58\u5728\uff0c\u5219\u6309\u987a\u5e8f\u5c06\u4e8b\u4ef6\u4f20\u9012\u7ed9\u5904\u7406\u51fd\u6570\u6267\u884c\r\n37             for handler in self.__handlers[event.type_]:\r\n38                 handler(event)\r\n39 \r\n40     def Start(self):\r\n41         \"\"\"\u542f\u52a8\"\"\"\r\n42         # \u5c06\u4e8b\u4ef6\u7ba1\u7406\u5668\u8bbe\u4e3a\u542f\u52a8\r\n43         self.__active = True\r\n44         # \u542f\u52a8\u4e8b\u4ef6\u5904\u7406\u7ebf\u7a0b\r\n45         self.__thread.start()\r\n46 \r\n47     def Stop(self):\r\n48         \"\"\"\u505c\u6b62\"\"\"\r\n49         # \u5c06\u4e8b\u4ef6\u7ba1\u7406\u5668\u8bbe\u4e3a\u505c\u6b62\r\n50         self.__active = False\r\n51         # \u7b49\u5f85\u4e8b\u4ef6\u5904\u7406\u7ebf\u7a0b\u9000\u51fa\r\n52         self.__thread.join()\r\n53 \r\n54     def AddEventListener(self, type_, handler):\r\n55         \"\"\"\u7ed1\u5b9a\u4e8b\u4ef6\u548c\u76d1\u542c\u5668\u5904\u7406\u51fd\u6570\"\"\"\r\n56         # \u5c1d\u8bd5\u83b7\u53d6\u8be5\u4e8b\u4ef6\u7c7b\u578b\u5bf9\u5e94\u7684\u5904\u7406\u51fd\u6570\u5217\u8868\uff0c\u82e5\u65e0\u5219\u521b\u5efa\r\n57         try:\r\n58             handlerList = self.__handlers[type_]\r\n59         except KeyError:\r\n60             handlerList = []\r\n61 \r\n62         self.__handlers[type_] = handlerList\r\n63         # \u82e5\u8981\u6ce8\u518c\u7684\u5904\u7406\u5668\u4e0d\u5728\u8be5\u4e8b\u4ef6\u7684\u5904\u7406\u5668\u5217\u8868\u4e2d\uff0c\u5219\u6ce8\u518c\u8be5\u4e8b\u4ef6\r\n64         if handler not in handlerList:\r\n65             handlerList.append(handler)\r\n66 \r\n67     def RemoveEventListener(self, type_, handler):\r\n68         \"\"\"\u79fb\u9664\u76d1\u542c\u5668\u7684\u5904\u7406\u51fd\u6570\"\"\"\r\n69         #\u8bfb\u8005\u81ea\u5df1\u8bd5\u7740\u5b9e\u73b0\r\n70 \r\n71     def SendEvent(self, event):\r\n72         \"\"\"\u53d1\u9001\u4e8b\u4ef6\uff0c\u5411\u4e8b\u4ef6\u961f\u5217\u4e2d\u5b58\u5165\u4e8b\u4ef6\"\"\"\r\n73         self.__eventQueue.put(event)\r\n74 \r\n75 \"\"\"\u4e8b\u4ef6\u5bf9\u8c61\"\"\"\r\n76 class Event:\r\n77     def __init__(self, type_=None):\r\n78         self.type_ = type_      # \u4e8b\u4ef6\u7c7b\u578b\r\n79         self.dict = {}          # \u5b57\u5178\u7528\u4e8e\u4fdd\u5b58\u5177\u4f53\u7684\u4e8b\u4ef6\u6570\u636e<\/pre>\n
\"\u590d\u5236\u4ee3\u7801\"<\/a><\/span><\/div>\n<\/div>\n
test.py<\/p>\n
\n
\"\u590d\u5236\u4ee3\u7801\"<\/a><\/span><\/div>\n
 1 # -*- encoding: UTF-8 -*-\r\n 2 \r\n 3 from threading import *\r\n 4 from EventManager import *\r\n 5 import time\r\n 6 \r\n 7 #\u4e8b\u4ef6\u540d\u79f0  \u65b0\u6587\u7ae0\r\n 8 EVENT_ARTICAL = \"Event_Artical\"\r\n 9 \r\n10 \r\n11 #\u4e8b\u4ef6\u6e90 \u516c\u4f17\u53f7\r\n12 class PublicAccounts:\r\n13     def __init__(self,eventManager):\r\n14         self.__eventManager = eventManager\r\n15 \r\n16     def WriteNewArtical(self):\r\n17         #\u4e8b\u4ef6\u5bf9\u8c61\uff0c\u5199\u4e86\u65b0\u6587\u7ae0\r\n18         event = Event(type_=EVENT_ARTICAL)\r\n19         event.dict[\"artical\"] = u'\u5982\u4f55\u5199\u51fa\u66f4\u4f18\u96c5\u7684\u4ee3\u7801\\n'\r\n20         #\u53d1\u9001\u4e8b\u4ef6\r\n21         self.__eventManager.SendEvent(event)\r\n22         print(u'\u516c\u4f17\u53f7\u53d1\u9001\u65b0\u6587\u7ae0')\r\n23 \r\n24 \r\n25 #\u76d1\u542c\u5668 \u8ba2\u9605\u8005\r\n26 class Listener:\r\n27     def __init__(self,username):\r\n28         self.__username = username\r\n29 \r\n30     #\u76d1\u542c\u5668\u7684\u5904\u7406\u51fd\u6570 \u8bfb\u6587\u7ae0\r\n31     def ReadArtical(self,event):\r\n32         print(u'%s \u6536\u5230\u65b0\u6587\u7ae0' % self.__username)\r\n33         print(u'\u6b63\u5728\u9605\u8bfb\u65b0\u6587\u7ae0\u5185\u5bb9\uff1a%s'  % event.dict[\"artical\"])\r\n34 \r\n35 \r\n36 \"\"\"\u6d4b\u8bd5\u51fd\u6570\"\"\"\r\n37 def test():\r\n38     listner1 = Listener(\"thinkroom\") #\u8ba2\u9605\u80051\r\n39     listner2 = Listener(\"steve\")#\u8ba2\u9605\u80052\r\n40 \r\n41     eventManager = EventManager()\r\n42 \r\n43     #\u7ed1\u5b9a\u4e8b\u4ef6\u548c\u76d1\u542c\u5668\u54cd\u5e94\u51fd\u6570(\u65b0\u6587\u7ae0)\r\n44     eventManager.AddEventListener(EVENT_ARTICAL, listner1.ReadArtical)\r\n45     eventManager.AddEventListener(EVENT_ARTICAL, listner2.ReadArtical)\r\n46     eventManager.Start()\r\n47 \r\n48     publicAcc = PublicAccounts(eventManager)\r\n49     while True:\r\n50         publicAcc.WriteNewArtical()\r\n51         time.sleep(2)\r\n52 \r\n53 if __name__ == '__main__':\r\n54     test()<\/pre>\n
\"\u590d\u5236\u4ee3\u7801\"<\/a><\/span><\/div>\n<\/div>\n<\/div>\n<\/div>\n","protected":false},"excerpt":{"rendered":"
python \u6a21\u62df\u4e8b\u4ef6\u89e6\u53d1\u673a\u5236 Even<\/p>\n","protected":false},"author":1,"featured_media":0,"comment_status":"open","ping_status":"open","sticky":false,"template":"","format":"standard","meta":{"colormag_page_container_layout":"default_layout","colormag_page_sidebar_layout":"default_layout","footnotes":""},"categories":[],"tags":[118],"class_list":["post-1287","post","type-post","status-publish","format-standard","hentry","tag-02-"],"_links":{"self":[{"href":"https:\/\/i007.cc\/wordpress\/wp-json\/wp\/v2\/posts\/1287","targetHints":{"allow":["GET"]}}],"collection":[{"href":"https:\/\/i007.cc\/wordpress\/wp-json\/wp\/v2\/posts"}],"about":[{"href":"https:\/\/i007.cc\/wordpress\/wp-json\/wp\/v2\/types\/post"}],"author":[{"embeddable":true,"href":"https:\/\/i007.cc\/wordpress\/wp-json\/wp\/v2\/users\/1"}],"replies":[{"embeddable":true,"href":"https:\/\/i007.cc\/wordpress\/wp-json\/wp\/v2\/comments?post=1287"}],"version-history":[{"count":0,"href":"https:\/\/i007.cc\/wordpress\/wp-json\/wp\/v2\/posts\/1287\/revisions"}],"wp:attachment":[{"href":"https:\/\/i007.cc\/wordpress\/wp-json\/wp\/v2\/media?parent=1287"}],"wp:term":[{"taxonomy":"category","embeddable":true,"href":"https:\/\/i007.cc\/wordpress\/wp-json\/wp\/v2\/categories?post=1287"},{"taxonomy":"post_tag","embeddable":true,"href":"https:\/\/i007.cc\/wordpress\/wp-json\/wp\/v2\/tags?post=1287"}],"curies":[{"name":"wp","href":"https:\/\/api.w.org\/{rel}","templated":true}]}}