def f1(i):time.sleep(1)print(i)if __name__ == '__main__':for i in range(5):t = threading.Thread(target=f1, args=(i,))t.start()print('start')          # 主线程等待子线程完成，子线程并发执行>>start
>>2
>>1
>>3
>>0
>>4

import threading
import timedef f1(i):time.sleep(1)print(i)if __name__ == '__main__':for i in range(5):t = threading.Thread(target=f1, args=(i,))t.start()t.join()print('start')      # 线程从上到下依次执行，最后打印出start>>0
>>1
>>2
>>3
>>4
>>start

import threading
import timedef f1(i):time.sleep(1)print(i)if __name__ == '__main__':for i in range(5):t = threading.Thread(target=f1, args=(i,))t.setDaemon(True)t.start()print('start')      # 主线程不等待子线程>> start　

import threading
G = 1
lock = threading.RLock()
def fun():lock.acquire()    # 获取锁global GG += 2print(G, threading.current_thread().name)lock.release()   # 释放锁returnfor i in range(10):t = threading.Thread(target=fun, name='t-{}'.format(i))t.start()3 t-0
5 t-1
7 t-2
9 t-3
11 t-4
13 t-5
15 t-6
17 t-7
19 t-8
21 t-9

import threading
import timedef f1(event):print('start:')event.wait()            # 阻塞在，等待 setprint('end:')if __name__ == '__main__':event_obj  = threading.Event()for i in range(5):t = threading.Thread(target=f1, args=(event_obj,))t.start()event_obj.clear()      # 清除标志位 inp = input('>>>>:')if inp == 'true':event_obj.set()   # 设置标志位

q = queue.Queue(maxsize=0)  # 构造一个先进显出队列，maxsize指定队列长度，为0时，表示队列长度无限制。q.join()    　　　　# 等到队列为kong的时候，在执行别的操作
q.qsize()   　　　　# 返回队列的大小 （不可靠）
q.empty()   　　　　# 当队列为空的时候，返回True 否则返回False （不可靠）
q.full()    　　　　# 当队列满的时候，返回True，否则返回False （不可靠）
q.put(item, block=True, timeout=None) 　　# 将item放入Queue尾部，item必须存在，参数block默认为True,表示当队列满时，会等待# 为False时为非阻塞，此时如果队列已满，会引发queue.Full 异常。 可选参数timeout，表示会阻塞设置的时间，# 如果在阻塞时间里 队列还是无法放入，则引发 queue.Full 异常q.get(block=True, timeout=None) 　　　　#  移除并返回队列头部的一个值，可选参数block默认为True，表示获取值的时候，如果队列为空，则阻塞#  阻塞的话若此时队列为空，则引发queue.Empty异常。 可选参数timeout，表示会阻塞设置的时间，
q.get_nowait() 　　　　　　　　　　　　　　#  等效于 get(item,block=False)　

message = queue.Queue(10)def product(num):for i in range(num):message.put(i)print('将{}添加到队列中'.format(i))time.sleep(random.randrange(0, 1))def consume(num):count = 0while count<num:i = message.get()print('将{}从队列取出'.format(i))time.sleep(random.randrange(1, 2))count += 1t1 = threading.Thread(target=product, args=(10, ))
t1.start()t2 = threading.Thread(target=consume, args=(10, ))
t2.start()

l = []def f(i):l.append(i)print('hi', l)if __name__ == '__main__':for i in range(10):p = multiprocessing.Process(target=f, args=(i,))        # 数据不共享，创建10份 l列表p.start()

def f(a, b):a.value = 3.111for i in range(len(b)):b[i] += 100if __name__ == '__main__':num = Value('f', 3.333)　　　　　　　　# 类似C语言中的 浮点型数l = Array('i', range(10))　　　　　　 # 类似C语言中的整形数组，长度为10print(num.value)print(l[:])p = Process(target=f, args=(num, l))p.start()p.join()print(num.value)　　　　　　　　　　　　　　# 大家自己运行一下，看下两次打印结果是否一样print(l[:])

from multiprocessing import Process,Managerdef Foo(dic, i):dic[i] = 100 + iprint(dic.values())if __name__ == '__main__':manage = Manager()dic = manage.dict()for i in range(2):p = Process(target=Foo, args=(dic, i))p.start()p.join()

from multiprocessing import Pool
import timedef f1(i):time.sleep(1)# print(i)return idef cb(i):print(i)if __name__ == '__main__':poo = Pool(5)for i in range(20):# poo.apply(func=f1, args=(i,))   # 串行执行，排队执行 有joinpoo.apply_async(func=f1, args=(i,), callback=cb)  # 并发执行 主进程不等子进程，无joinprint('**********')poo.close()poo.join()

import threading
import time
import queueclass ThreadPool:def __init__(self, max_num=20):self.queue = queue.Queue(max_num)for i in range(max_num):self.add()def add(self):self.queue.put(threading.Thread)def get(self):return self.queue.get()def f(tp, i):time.sleep(1)print(i)tp.add()p = ThreadPool(10)
for i in range(20):thread = p.get()t = thread(target=f, args=(p, i))t.start()

import threading
import queue
import time
import contextlibclass ThreadingPool:def __init__(self, num):self.max = numself.terminal = Falseself.q = queue.Queue()self.generate_list = []         # 保存已经生成的线程self.free_list = []             # 保存那些已经完成任务的线程def run(self, func, args=None, callbk=None):self.q.put((func, args, callbk))            # 将任务信息作为一个元祖放到队列中去if len(self.free_list) == 0 and len(self.generate_list) < self.max:self.threadstart()def threadstart(self):t = threading.Thread(target=self.handel)t.start()def handel(self):current_thread = threading.current_thread()self.generate_list.append(current_thread)event = self.q.get()while event != 'stop':func, args, callbk = eventflag = Truetry:ret = func(*args)except Exception as e:flag = Falseret = eif callbk is not None:try:callbk(ret)except Exception as e:passif not self.terminal:with self.auto_append_remove(current_thread):event = self.q.get()else:event = 'stop'else:self.generate_list.remove(current_thread)def terminate(self):self.terminal = Truewhile self.generate_list:self.q.put('stop')self.q.empty()def close(self):num = len(self.generate_list)while num:self.q.put('stop')num -= 1@contextlib.contextmanagerdef auto_append_remove(self, thread):self.free_list.append(thread)try:yieldfinally:self.free_list.remove(thread)def f(i):# time.sleep(1)return idef f1(i):print(i)p = ThreadingPool(5)
for i in range(20):p.run(func=f, args=(i,), callbk=f1)p.close()

from gevent import monkey
import gevent
import requests# 把标准库中的thread/socket等给替换掉
# 这样我们在后面使用socket的时候可以跟平常一样使用,无需修改任何代码,但是它变成非阻塞的了.
monkey.patch_all()　　　　　　# 猴子补丁def f(url):print('GET: %s' % url)resp = requests.get(url)data = resp.textprint('%d bytes received from %s.' % (len(data), url))gevent.joinall([gevent.spawn(f, 'https://www.python.org/'),gevent.spawn(f, 'https://www.yahoo.com/'),gevent.spawn(f, 'https://github.com/'),
])