from concurrent.futures import ProcessPoolExecutor,ThreadPoolExecutor

import time,os,random

def task(n):

    print(os.getpid(),'is running')

    time.sleep(random.randint(,))

    return n**

if __name__ == '__main__':

    p = ProcessPoolExecutor()

    obj = p.map(task,range())

    p.shutdown()

    print(list(obj))

import os,time,requests,re

from concurrent.futures import ThreadPoolExecutor

def get_page(url):

    print(url)

    ret = requests.get(url).text

    return {'url':url,'text':ret}

def get_p(res):

    res  = res.result()

    rep = re.compile(r'<a href="/films/\d+" title="(?P<name>.*?)" class="image-link.*?<p class="star">(?P<star>.*?)</p>',re.S)

    ret = rep.finditer(res['text'])

    with open('db.txt','a',encoding='utf-8')as f:

        for i in ret:

            s = "name:%s"%i.group("name")+i.group('star')

            f.write(s+'\n')

if __name__ == '__main__':

    t = time.time()

    p = ThreadPoolExecutor()

    urls = [

        'http://maoyan.com/board/7',

        'http://maoyan.com/board/6',

        'http://maoyan.com/board/1',

        'http://maoyan.com/board/2',

        'http://maoyan.com/board/4',

    ]

    for url in urls:

        p.submit(get_page,url).add_done_callback(get_p)

    p.shutdown()

    print(time.time()-t)

from greenlet import greenlet

def eat(name):

    print('%s eat 1' %name)

    g2.switch('egon')

    print('%s eat 2' %name)

    g2.switch()

def play(name):

    print('%s play 1' %name)

    g1.switch()

    print('%s play 2' %name)

g1=greenlet(eat)

g2=greenlet(play)

g1.switch('egon')#可以在第一次switch时传入参数，以后都不需要

from gevent import monkey;monkey.patch_all()

import gevent

import time

def eat():

    print('eat food 1')

    time.sleep()

    print('eat food 2')

def play():

    print('play 1')

    time.sleep()

    print('play 2')

g1=gevent.spawn(eat)

g2=gevent.spawn(play_phone)

gevent.joinall([g1,g2])

print('主')

from gevent import monkey;monkey.patch_all()

import gevent

import requests

import time

def get_page(url):

    print('GET: %s' %url)

    response=requests.get(url)

    if response.status_code == :

        print('%d bytes received from %s' %(len(response.text),url))

start_time=time.time()

gevent.joinall([

    gevent.spawn(get_page,'https://www.python.org/'),

    gevent.spawn(get_page,'https://www.yahoo.com/'),

    gevent.spawn(get_page,'https://github.com/'),

])

stop_time=time.time()

print('run time is %s' %(stop_time-start_time))

from gevent import monkey;monkey.patch_all()

from socket import *

import gevent

#如果不想用money.patch_all()打补丁,可以用gevent自带的socket

# from gevent import socket

# s=socket.socket()

def server(server_ip,port):

    s=socket(AF_INET,SOCK_STREAM)

    s.setsockopt(SOL_SOCKET,SO_REUSEADDR,)

    s.bind((server_ip,port))

    s.listen()

    while True:

        conn,addr=s.accept()

        gevent.spawn(talk,conn,addr)

def talk(conn,addr):

    try:

        while True:

            res=conn.recv()

            print('client %s:%s msg: %s' %(addr[],addr[],res))

            conn.send(res.upper())

    except Exception as e:

        print(e)

    finally:

        conn.close()

if __name__ == '__main__':

    server('127.0.0.1',)

from threading import Thread

from socket import *

import threading

def client(server_ip,port):

    c=socket(AF_INET,SOCK_STREAM) #套接字对象一定要加到函数内，即局部名称空间内，放在函数外则被所有线程共享，则大家公用一个套接字对象，那么客户端端口永远一样了

    c.connect((server_ip,port))

    count=

    while True:

        c.send(('%s say hello %s' %(threading.current_thread().getName(),count)).encode('utf-8'))

        msg=c.recv()

        print(msg.decode('utf-8'))

        count+=

if __name__ == '__main__':

    for i in range():

        t=Thread(target=client,args=('127.0.0.1',))

        t.start()