from  concurrent.futures import ThreadPoolExecutor,as_completed
from concurrent.futures import ProcessPoolExecutor
import timedef fib(n):if n<=2:return 1return fib(n-1) + fib(n-2)if __name__ == '__main__':with ThreadPoolExecutor(3) as executor:all_task = [executor.submit(fib,(num)) for num in range(25,40)]start_time = time.time()for future in as_completed(all_task):data = future.result()print("get result:= {}".format(data))print("multithread last time is {}".format(time.time()-start_time))with ProcessPoolExecutor(3) as executor:all_task = [executor.submit(fib,(num)) for num in range(25,40)]start_time = time.time()for future in as_completed(all_task):data = future.result()print("get result:= {}".format(data))print("multiprocess last time is {}".format(time.time()-start_time))
#
# multithread last time is 43.156678199768066
# multiprocess last time is 27.62783455848694

from  concurrent.futures import ThreadPoolExecutor,as_completed
from concurrent.futures import ProcessPoolExecutor
import timedef random_sleep(n):time.sleep(n)return nif __name__ == '__main__':with ThreadPoolExecutor(3) as executor:all_task = [executor.submit(random_sleep,(num)) for num in [2]*30]start_time = time.time()for future in as_completed(all_task):data = future.result()print("get result:= {}".format(data))print("multithread last time is {}".format(time.time()-start_time))with ProcessPoolExecutor(3) as executor:all_task = [executor.submit(random_sleep,(num)) for num in [2]*30]start_time = time.time()for future in as_completed(all_task):data = future.result()print("get result:= {}".format(data))print("multiprocess last time is {}".format(time.time()-start_time))
#
# multithread last time is 20.035860300064087
# multiprocess last time is 20.641016483306885

import os
import time
# fork只能用于linux下面
pid = os.fork()
print("bobby")
if pid == 0:print("子进程{},父进程是{}".format(os.getpid(),os.getppid()))
else:print("我是父进程：{}".format(pid))time.sleep(2)

import multiprocessing
import time
def get_html(n):time.sleep(n)return nif __name__ == '__main__':progress = multiprocessing.Process(target=get_html,args=(2,))progress.start()progress.join()

import multiprocessing
import time
from multiprocessing import Pooldef get_html(n):time.sleep(n)return nif __name__ == '__main__':progress = multiprocessing.Process(target=get_html,args=(1,))progress.start()progress.join()pool = Pool(multiprocessing.cpu_count())print(multiprocessing.cpu_count())result = pool.apply_async(get_html,args=(3,))pool.close()

for result in  pool.imap(get_html,[1,5,3]):

from multiprocessing import Process,Queue
# from queue import Queue  # 这个queue就不能用了
import timedef producer(queue):queue.put("a")time.sleep(2)def consumer(queue):time.sleep(2)data = queue.get()print(data)if __name__ == '__main__':queue = Queue(10)my_producer = Process(target=producer,args=(queue,))my_consumer = Process(target=consumer, args=(queue,))my_producer.start()my_consumer.start()my_producer.join()my_consumer.join()

from multiprocessing import Process
import timedef producer(a):a += 1time.sleep(2)def consumer(a):time.sleep(2)print(a)if __name__ == '__main__':a = 1my_producer = Process(target=producer,args=(a,))my_consumer = Process(target=consumer, args=(a,))my_producer.start()my_consumer.start()my_producer.join()my_consumer.join()

from multiprocessing import Process,Queue,Manager,Pool
import timedef producer(queue):queue.put("a")time.sleep(2)def consumer(queue):time.sleep(2)data = queue.get()print(data)if __name__ == '__main__':queue = Manager().Queue(10)pool = Pool(2)pool.apply_async(producer,args=(queue,))pool.apply_async(consumer, args=(queue,))pool.close()pool.join()

from multiprocessing import Process,Queue,Manager,Pool,Pipe
import timedef producer(pipe):pipe.send("bobby")def consumer(pipe):print(pipe.recv())if __name__ == '__main__':# pipe只能用于两个进程间的通讯receive_pipe,send_pipe = Pipe()my_producer = Process(target=producer,args=(send_pipe,))my_consumer = Process(target=consumer, args=(receive_pipe,))my_producer.start()my_consumer.start()my_producer.join()my_consumer.join()

from multiprocessing import Process,Queue,Manager,Pool,Pipedef add_data(p_dict,key,value):p_dict[key] = valueif __name__ == '__main__':progress_dict = Manager().dict()first_progess = Process(target=add_data,args=(progress_dict,"bobby1",22))second_progess = Process(target=add_data, args=(progress_dict, "bobby1", 23))first_progess.start()second_progess.start()first_progess.join()second_progess.join()print(progress_dict)
# {'bobby1': 23}