Process、Thread、Coroutine in Python

import asyncio
import threading
import time


async def foo():
    print('foo start')
    print("foo thread is {}".format(threading.currentThread()))
    await asyncio.sleep(1)
    print('foo finish')


async def bar():
    print('bar start')
    print("bar thread is {}".format(threading.currentThread()))
    await asyncio.sleep(1)
    print('bar finish')


print("main thread is {}".format(threading.currentThread()))
start = time.time()
loop = asyncio.get_event_loop()
tasks = [foo(), bar()]
loop.run_until_complete(asyncio.wait(tasks))
loop.close()
end = time.time()
print("运行时间是: {}".format(end-start))

import threading
import time
from concurrent.futures import ThreadPoolExecutor

_executor = ThreadPoolExecutor(2)


def foo(array):
    print("foo start")
    print("foo thread {}".format(threading.currentThread()))
    time.sleep(1)
    array.append("foo")
    print("foo end time is {}".format(time.time()))


def bar(array):
    print("bar start")
    print("bar thread {}".format(threading.currentThread()))
    time.sleep(1)
    array.append("bar")
    print("bar end time is {}".format(time.time()))


start = time.time()
print("start time is {}".format(time.time()))
print("main thread {}".format(threading.currentThread()))
my_list = []
print("init list is {}".format(my_list))
executor = ThreadPoolExecutor(max_workers=2)
executor.submit(foo, my_list)
executor.submit(bar, my_list)
print("finally list is {}".format(my_list))
end = time.time()
print("运行时间是: {}".format(end-start))

import asyncio
import threading
import time
from concurrent.futures import ThreadPoolExecutor

_executor = ThreadPoolExecutor(2)

async def foo(array):
    print('foo start')
    print("foo thread is {}".format(threading.currentThread()))
    foo_loop = asyncio.get_event_loop()
    await foo_loop.run_in_executor(_executor, my_func, array, "foo")
    print('foo finish')


async def bar(array):
    print('bar start')
    print("bar thread is {}".format(threading.currentThread()))
    bar_loop = asyncio.get_event_loop()
    await bar_loop.run_in_executor(_executor, my_func, array, "bar")
    print('bar finish')


def my_func(array, item):
    print("my_func thread is {}".format(threading.currentThread()))
    array.append(item)
    time.sleep(1)


print("main thread is {}".format(threading.currentThread()))
start = time.time()
my_list = []
print("init list is {}".format(my_list))
loop = asyncio.get_event_loop()
tasks = [foo(my_list), bar(my_list)]
loop.run_until_complete(asyncio.wait(tasks))
loop.close()
end = time.time()
print("finally list is {}".format(my_list))
print("运行时间是: {}".format(end-start))

import asyncio
import threading
import time
from concurrent.futures import ThreadPoolExecutor


async def foo(array, item):
    print('foo start')
    print("foo thread is {}".format(threading.currentThread()))
    bar_loop = asyncio.get_event_loop()
    _executor = ThreadPoolExecutor(1)
    await bar_loop.run_in_executor(_executor, my_func, array, item)
    print('foo finish')


def my_func(array, item):
    print("my_func thread is {}".format(threading.currentThread()))
    array.append(item)
    time.sleep(1)


print("main thread is {}".format(threading.currentThread()))
start = time.time()
my_list = []
print("init list is {}".format(my_list))
loop = asyncio.get_event_loop()
tasks = [foo(my_list, i) for i in range(10)]
loop.run_until_complete(asyncio.wait(tasks))
loop.close()
end = time.time()
print("finally list is {}".format(my_list))
print("运行时间是: {}".format(end-start))

import concurrent.futures
import math
import time

PRIMES = [
    112272535095293,
    112582705942171,
    112272535095293,
    115280095190773,
    115797848077099,
    1099726899285419]

def is_prime(n, m=None):
    time.sleep(1)
    print("{}-{}".format(n ,m))

    if n % 2 == 0:
        return False

    sqrt_n = int(math.floor(math.sqrt(n)))
    for i in range(3, sqrt_n + 1, 2):
        if n % i == 0:
            return False
    return True

def main():
    with concurrent.futures.ProcessPoolExecutor() as executor:
        # 这里有三种写法, 可以灵活使用

        # 第一种
        # futures = {executor.submit(is_prime, i): i for i in PRIMES}
        # for f in concurrent.futures.as_completed(futures):
        #     i = futures[f]
        #     data = f.result()
        #     print("{} {}".format(i, data))

        # 第二种, 注: 如果is_prime有两个参数, submit则增加一个参数
        # for i in PRIMES:
        #     executor.submit(is_prime, i, 2)

        # 第三种
        for number, prime in zip(PRIMES, executor.map(is_prime, PRIMES)):
            print('%d is prime: %s' % (number, prime))

if __name__ == '__main__':
    t1 = time.time()
    main()
    print("耗时{}".format(time.time()-t1))

import asyncio
import threading
import time
from concurrent.futures import ProcessPoolExecutor


async def foo(array):
    print('foo start')
    print("foo thread is {}".format(threading.currentThread()))
    foo_loop = asyncio.get_event_loop()
    _executor = ProcessPoolExecutor()
    tasks = [foo_loop.run_in_executor(_executor, my_func, array, item) for item in range(10)]
    completed, pending = await asyncio.wait(tasks)
    results = [t.result() for t in completed]
    print('results: {!r}'.format(results))
    print('foo finish')
    return results


def my_func(array, item):
    print("my_func thread is {}".format(threading.currentThread()))
    array.append(item)
    time.sleep(1)
    return item


print("main thread is {}".format(threading.currentThread()))
start = time.time()
my_list = []
print("init my list is {}".format(my_list))
loop = asyncio.get_event_loop()
result = loop.run_until_complete(foo(my_list))
loop.close()
end = time.time()
print("finally my list is {}".format(my_list))
print("result list is {}".format(result))
print("运行时间是: {}".format(end-start))