{"id":129,"date":"2016-08-31T17:37:54","date_gmt":"2016-08-31T09:37:54","guid":{"rendered":"http:\/\/ayonel.me\/?p=129"},"modified":"2016-09-07T17:17:34","modified_gmt":"2016-09-07T09:17:34","slug":"some_python_code","status":"publish","type":"post","link":"https:\/\/ayonel.malash.net\/index.php\/2016\/08\/31\/some_python_code\/","title":{"rendered":"\u4e00\u4e9b\u6709\u610f\u601d\u7684python\u4ee3\u7801\u7247\u6bb5"},"content":{"rendered":"

\u672c\u6587\u6253\u7b97\u957f\u671f\u66f4\u65b0\u4e00\u4e9b\u6709\u610f\u601d\u7684python\u4ee3\u7801\u7247\u6bb5\uff0c\u5c31\u5f53\u505a\u662f\u5b66\u4e60\u7b14\u8bb0\u3002<\/p>\n

1.python\u591a\u7ebf\u7a0b\u6b7b\u9501<\/h3>\n
import<\/span> time<\/span>,<\/span>threading<\/span>
\n
\nlocka =<\/span> threading<\/span>.Lock<\/span>(<\/span>)<\/span>
\nlockb =<\/span> threading<\/span>.Lock<\/span>(<\/span>)<\/span>
\n
\ndef<\/span> fa(<\/span>)<\/span>:
\n    print<\/span>(<\/span>'a'<\/span>)<\/span>
\ndef<\/span> fb(<\/span>)<\/span>:
\n    print<\/span>(<\/span>'b'<\/span>)<\/span>
\n
\ndef<\/span> fab(<\/span>)<\/span>:
\n    locka.acquire<\/span>(<\/span>)<\/span>
\n    try<\/span>:
\n        fa(<\/span>)<\/span>
\n        time<\/span>.sleep<\/span>(<\/span>1<\/span>)<\/span>
\n        lockb.acquire<\/span>(<\/span>)<\/span>
\n        try<\/span>:
\n            fb(<\/span>)<\/span>
\n        finally<\/span>:
\n            lockb.release<\/span>(<\/span>)<\/span>
\n    finally<\/span>:
\n        locka.release<\/span>(<\/span>)<\/span>
\ndef<\/span> fba(<\/span>)<\/span>:
\n    lockb.acquire<\/span>(<\/span>)<\/span>
\n    try<\/span>:
\n        fb(<\/span>)<\/span>
\n        time<\/span>.sleep<\/span>(<\/span>1<\/span>)<\/span>
\n        locka.acquire<\/span>(<\/span>)<\/span>
\n        try<\/span>:
\n            fa(<\/span>)<\/span>
\n        finally<\/span>:
\n            locka.release<\/span>(<\/span>)<\/span>
\n    finally<\/span>:
\n        lockb.release<\/span>(<\/span>)<\/span>
\n
\nt1 =<\/span> threading<\/span>.Thread<\/span>(<\/span>target=<\/span>fab)<\/span>
\nt2 =<\/span> threading<\/span>.Thread<\/span>(<\/span>target=<\/span>fba)<\/span>
\nt1.start<\/span>(<\/span>)<\/span>
\nt2.start<\/span>(<\/span>)<\/span>
\nt1.join<\/span>(<\/span>)<\/span>
\nt2.join<\/span>(<\/span>)<\/span>
\nprint<\/span>(<\/span>'end'<\/span>)<\/span><\/div><\/div>\n

2.\u534f\u7a0bcoroutine(1)<\/h3>\n

\u6765\u6e90\uff1a\u5ed6\u96ea\u5cf0<\/a><\/p>\n

def<\/span> consumer(<\/span>)<\/span>:
\n    r =<\/span> ''<\/span>
\n    while<\/span> True<\/span>:
\n
\n        n =<\/span> yield<\/span> r
\n        if<\/span> not<\/span> n:
\n            return<\/span>
\n        print<\/span>(<\/span>'[CONSUMER] Consuming %s...'<\/span> % n)<\/span>
\n        r =<\/span> '200 OK'<\/span>
\n
\ndef<\/span> produce(<\/span>c)<\/span>:
\n    c.send<\/span>(<\/span>None<\/span>)<\/span>
\n    n =<\/span> 0<\/span>
\n    while<\/span> n <<\/span> 5<\/span>:
\n        n =<\/span> n + 1<\/span>
\n        print<\/span>(<\/span>'[PRODUCER] Producing %s...'<\/span> % n)<\/span>
\n        r =<\/span> c.send<\/span>(<\/span>n)<\/span>
\n        print<\/span>(<\/span>'[PRODUCER] Consumer return: %s'<\/span> % r)<\/span>
\n    c.close<\/span>(<\/span>)<\/span>
\n
\nc =<\/span> consumer(<\/span>)<\/span>
\nproduce(<\/span>c)<\/span><\/div><\/div>\n

\u8fd0\u884c\u7ed3\u679c\u4e3a\uff1a<\/p>\n

[PRODUCER] Producing 1...
\n[CONSUMER] Consuming 1...
\n[PRODUCER] Consumer return: 200 OK
\n[PRODUCER] Producing 2...
\n[CONSUMER] Consuming 2...
\n[PRODUCER] Consumer return: 200 OK
\n[PRODUCER] Producing 3...
\n[CONSUMER] Consuming 3...
\n[PRODUCER] Consumer return: 200 OK
\n[PRODUCER] Producing 4...
\n[CONSUMER] Consuming 4...
\n[PRODUCER] Consumer return: 200 OK
\n[PRODUCER] Producing 5...
\n[CONSUMER] Consuming 5...
\n[PRODUCER] Consumer return: 200 OK<\/div><\/div>\n

\u89e3\u91ca\uff1a
\nyield\u8868\u8fbe\u5f0f\u672c\u8eab\u6ca1\u6709\u8fd4\u56de\u503c\uff0c\u5b83\u7684\u8fd4\u56de\u503c\u9700\u8981\u7b49\u5230\u4e0b\u6b21\u8c03\u7528generator\u51fd\u6570\u65f6\uff0c\u7531send(args)\u51fd\u6570\u7684\u53c2\u6570\u8d4b\u4e88\u3002
\n<\/strong><\/p>\n

3.\u534f\u7a0bcoroutine(2)<\/h3>\n

\u6765\u6e90\uff1ahttp:\/\/blog.csdn.net\/gvfdbdf\/article\/details\/49254037<\/a><\/p>\n

# -*- \u5f02\u6b65IO -*-  <\/span>
\nimport<\/span> asyncio  
\nimport<\/span> threading<\/span>  
\n 
\n# @asyncio.coroutine\u628a\u4e00\u4e2agenerator\u6807\u8bb0\u4e3acoroutine\u7c7b\u578b  <\/span>
\n@<\/span>asyncio.coroutine<\/span>  
\ndef<\/span> sub(<\/span>)<\/span>:  
\n    print<\/span>(<\/span>'sub start: ...'<\/span>)<\/span>  
\n    n =<\/span> 10<\/span>  
\n    while<\/span> True<\/span>:  
\n        print<\/span>(<\/span>'yield start'<\/span>)<\/span>  
\n        # asyncio.sleep()\u4e5f\u662f\u4e00\u4e2acoroutine\u7c7b\u578b\u7684generator\uff0c\u6240\u4ee5\u7ebf\u7a0b\u4e0d\u4f1a\u4e2d\u65ad\uff0c\u800c\u662f\u76f4\u63a5\u6267\u884c\u4e0b\u4e00\u4e2a\u5faa\u73af\uff0c\u7b49\u5f85yield from\u7684\u8fd4\u56de  <\/span>
\n        # \u53ef\u4ee5\u7b80\u5355\u7684\u7406\u89e3\u4e3a\u51fa\u73b0yield\u4e4b\u540e\u5219\u5f00\u542f\u4e00\u4e2a\u534f\u7a0b(\u7c7b\u4f3c\u5f00\u542f\u4e00\u4e2a\u65b0\u7ebf\u7a0b),\u4e0d\u7ba1\u8fd9\u4e2a\u534f\u7a0b\u662f\u5426\u6267\u884c\u5b8c\u6bd5\uff0c\u7ee7\u7eed\u4e0b\u4e00\u4e2a\u5faa\u73af  <\/span>
\n        # \u5f00\u542f\u65b0\u534f\u7a0b\u540e\uff0cprint('yield start')\u4f1a\u56e0\u4e3a\u7ee7\u7eed\u6267\u884c\u5faa\u73af\u88ab\u7acb\u5373\u6267\u884c\uff0c\u53ef\u4ee5\u901a\u8fc7\u6253\u5370\u7ed3\u679c\u89c2\u5bdf  <\/span>
\n        r =<\/span> yield<\/span> from<\/span> asyncio.sleep<\/span>(<\/span>1<\/span>)<\/span>  
\n        n =<\/span> n - 1<\/span>  
\n        print<\/span>(<\/span>'---sub: %s,  thread:%s'<\/span> %(<\/span>n,<\/span> threading<\/span>.currentThread<\/span>(<\/span>)<\/span>)<\/span>)<\/span>  
\n        if<\/span> n ==<\/span> 0<\/span>:  
\n            break<\/span>  
\n 
\n@<\/span>asyncio.coroutine<\/span>  
\ndef<\/span> add(<\/span>)<\/span>:  
\n    print<\/span>(<\/span>'add start: ...'<\/span>)<\/span>  
\n    n =<\/span> 10<\/span>  
\n    while<\/span> True<\/span>:  
\n        print<\/span>(<\/span>'yield start'<\/span>)<\/span>  
\n        r =<\/span> yield<\/span> from<\/span> asyncio.sleep<\/span>(<\/span>2<\/span>)<\/span>  
\n        n =<\/span> n + 1<\/span>  
\n        print<\/span>(<\/span>'+++add: %s,  thread:%s'<\/span> %(<\/span>n,<\/span> threading<\/span>.currentThread<\/span>(<\/span>)<\/span>)<\/span>)<\/span>  
\n        if<\/span> n ><\/span> 20<\/span>:  
\n            break<\/span>  
\n 
\n 
\n# \u83b7\u53d6EventLoop:  <\/span>
\nloop =<\/span> asyncio.get_event_loop<\/span>(<\/span>)<\/span>  
\n# \u6267\u884ccoroutine  <\/span>
\ntasks =<\/span> [<\/span>add(<\/span>)<\/span>,<\/span>sub(<\/span>)<\/span>]<\/span>  
\nloop.run_until_complete<\/span>(<\/span>asyncio.wait<\/span>(<\/span>tasks)<\/span>)<\/span>  
\nloop.close<\/span>(<\/span>)<\/span><\/div><\/div>\n

\u6267\u884c\u7ed3\u679c\uff1a<\/p>\n

add start: ...
\nyield start add
\nsub start: ...
\nyield start sub
\n---sub: 9,  thread:<_MainThread(MainThread, started 140735116865536)>
\nyield start sub
\n+++add: 11,  thread:<_MainThread(MainThread, started 140735116865536)>
\nyield start add
\n---sub: 8,  thread:<_MainThread(MainThread, started 140735116865536)>
\nyield start sub
\n---sub: 7,  thread:<_MainThread(MainThread, started 140735116865536)>
\nyield start sub
\n+++add: 12,  thread:<_MainThread(MainThread, started 140735116865536)>
\nyield start add
\n---sub: 6,  thread:<_MainThread(MainThread, started 140735116865536)>
\nyield start sub
\n---sub: 5,  thread:<_MainThread(MainThread, started 140735116865536)>
\nyield start sub
\n+++add: 13,  thread:<_MainThread(MainThread, started 140735116865536)>
\nyield start add
\n---sub: 4,  thread:<_MainThread(MainThread, started 140735116865536)>
\nyield start sub
\n---sub: 3,  thread:<_MainThread(MainThread, started 140735116865536)>
\nyield start sub
\n+++add: 14,  thread:<_MainThread(MainThread, started 140735116865536)>
\nyield start add
\n......<\/div><\/div>\n","protected":false},"excerpt":{"rendered":"

\u672c\u6587\u6253\u7b97\u957f\u671f\u66f4\u65b0\u4e00\u4e9b\u6709\u610f\u601d\u7684python\u4ee3\u7801\u7247\u6bb5\uff0c\u5c31\u5f53\u505a\u662f\u5b66\u4e60\u7b14\u8bb0\u3002 1.python\u591a\u7ebf\u7a0b\u6b7b\u9501 import […]<\/p>\n","protected":false},"author":1,"featured_media":0,"comment_status":"open","ping_status":"open","sticky":false,"template":"","format":"standard","meta":{"footnotes":""},"categories":[5],"tags":[],"class_list":["post-129","post","type-post","status-publish","format-standard","hentry","category-python"],"_links":{"self":[{"href":"https:\/\/ayonel.malash.net\/index.php\/wp-json\/wp\/v2\/posts\/129","targetHints":{"allow":["GET"]}}],"collection":[{"href":"https:\/\/ayonel.malash.net\/index.php\/wp-json\/wp\/v2\/posts"}],"about":[{"href":"https:\/\/ayonel.malash.net\/index.php\/wp-json\/wp\/v2\/types\/post"}],"author":[{"embeddable":true,"href":"https:\/\/ayonel.malash.net\/index.php\/wp-json\/wp\/v2\/users\/1"}],"replies":[{"embeddable":true,"href":"https:\/\/ayonel.malash.net\/index.php\/wp-json\/wp\/v2\/comments?post=129"}],"version-history":[{"count":10,"href":"https:\/\/ayonel.malash.net\/index.php\/wp-json\/wp\/v2\/posts\/129\/revisions"}],"predecessor-version":[{"id":146,"href":"https:\/\/ayonel.malash.net\/index.php\/wp-json\/wp\/v2\/posts\/129\/revisions\/146"}],"wp:attachment":[{"href":"https:\/\/ayonel.malash.net\/index.php\/wp-json\/wp\/v2\/media?parent=129"}],"wp:term":[{"taxonomy":"category","embeddable":true,"href":"https:\/\/ayonel.malash.net\/index.php\/wp-json\/wp\/v2\/categories?post=129"},{"taxonomy":"post_tag","embeddable":true,"href":"https:\/\/ayonel.malash.net\/index.php\/wp-json\/wp\/v2\/tags?post=129"}],"curies":[{"name":"wp","href":"https:\/\/api.w.org\/{rel}","templated":true}]}}