import osimport timeimport threadingdef fun(n):print('子线程开始运行……')time.sleep(1)my_thread_name = threading.current_thread().name#获取当前线程名称my_thread_id = threading.current_thread().ident#获取当前线程idprint('当前线程为：{}，线程id为：{}，所在进程为：{},您输入的参数为：{}'.format(my_thread_name ,my_thread_id , os.getpid(),n))print('子线程运行结束……')t = threading.Thread(target=fun , name='线程1',args=('参数1',))t.start()time.sleep(2)main_thread_name = threading.current_thread().name#获取当前线程名称main_thread_id = threading.current_thread().ident#获取当前线程idprint('主线程为：{}，线程id为：{}，所在进程为：{}'.format(main_thread_name ,main_thread_id , os.getpid()))

import osimport timeimport threadingclass MyThread(threading.Thread):def __init__(self , n , name=None):super().__init__()self.name = nameself.n = ndef run(self):print('子线程开始运行……')time.sleep(1)my_thread_name = threading.current_thread().name#获取当前线程名称my_thread_id = threading.current_thread().ident#获取当前线程idprint('当前线程为：{}，线程id为：{}，所在进程为：{},您输入的参数为：{}'.format(my_thread_name ,my_thread_id , os.getpid(),self.n))print('子线程运行结束……')t = MyThread(name='线程1', n=1)t.start()time.sleep(2)main_thread_name = threading.current_thread().name#获取当前线程名称main_thread_id = threading.current_thread().ident#获取当前线程idprint('主线程为：{}，线程id为：{}，所在进程为：{}'.format(main_thread_name ,main_thread_id , os.getpid()))

import osimport timeimport threadingdef fun():print('子线程开始运行……')for i in range(6):#运行3秒，每秒输出一次time.sleep(1)my_thread_name = threading.current_thread().nameprint('{}已运行{}秒……'.format(my_thread_name ,i+1))print('子线程运行结束……')print('主线程开始运行……')t = threading.Thread(target=fun , name='线程1')print('daemon的值为：{}'.format(t.daemon))t.start()for i in range(3):time.sleep(1)my_thread_name = threading.current_thread().nameprint('{}已运行{}秒……'.format(my_thread_name, i+1))print('主线程结束运行……')

import timeimport threadingdef fun():print('子线程开始运行……')for i in range(6):#运行3秒，每秒输出一次time.sleep(1)my_thread_name = threading.current_thread().nameprint('{}已运行{}秒……'.format(my_thread_name ,i+1))print('子线程运行结束……')print('主线程开始运行……')t = threading.Thread(target=fun , name='线程1')t.daemon=True #设置为守护线程print('daemon的值为：{}'.format(t.daemon))t.start()for i in range(3):time.sleep(1)my_thread_name = threading.current_thread().nameprint('{}已运行{}秒……'.format(my_thread_name, i+1))print('主线程结束运行……')

import timeimport threadingdef fun():print('子线程开始运行……')for i in range(6):#运行3秒，每秒输出一次time.sleep(1)my_thread_name = threading.current_thread().nameprint('{}已运行{}秒……'.format(my_thread_name ,i+1))print('子线程运行结束……')print('主线程开始运行……')t = threading.Thread(target=fun , name='线程1')t.daemon=True #设置为守护线程t.start()t.join() #此处进行joinfor i in range(3):time.sleep(1)my_thread_name = threading.current_thread().nameprint('{}已运行{}秒……'.format(my_thread_name, i+1))print('主线程结束运行……')

import timeimport threadingdef fun():print('子线程开始运行……')for i in range(6):#运行3秒，每秒输出一次time.sleep(1)my_thread_name = threading.current_thread().nameprint('{}已运行{}秒……'.format(my_thread_name ,i+1))print('子线程运行结束……')print('主线程开始运行……')t = threading.Thread(target=fun , name='线程1')t.daemon=True #设置为守护线程t.start()for i in range(3):time.sleep(1)my_thread_name = threading.current_thread().nameprint('{}已运行{}秒……'.format(my_thread_name, i+1))t.join()print('主线程结束运行……')

import timeimport threadingdef fun():global numtemp = numtime.sleep(0.2)temp -= 1num = tempprint('主线程开始运行……')t_lst = []num =10 # 全局变量for i in range(10):t = threading.Thread(target=fun)t_lst.append(t)t.start()[t.join() for t in t_lst]print('num最后的值为：{}'.format(num))print('主线程结束运行……')

import timeimport threadingdef fun(lock):lock.acquire()global numtemp = numtime.sleep(0.2)temp -= 1num = templock.release()print('主线程开始运行……')t_lst = []num =10 # 全局变量lock = threading.Lock()for i in range(10):t = threading.Thread(target=fun , args=(lock,))t_lst.append(t)t.start()[t.join() for t in t_lst]print('num最后的值为：{}'.format(num))print('主线程结束运行……')

import timefrom threading import Threadfrom threading import Lockdef eatNoodles_1(noodle_lock, fork_lock, scientist):noodle_lock.acquire()print('{} 拿到了面'.format(scientist))fork_lock.acquire()print('{} 拿到了叉子'.format(scientist))time.sleep(1)print('{} 吃到了面'.format(scientist))fork_lock.release()noodle_lock.release()print('{} 放下了面'.format(scientist))print('{} 放下了叉子'.format(scientist))def eatNoodles_2(noodle_lock, fork_lock, scientist):fork_lock.acquire()print('{} 拿到了叉子'.format(scientist))noodle_lock.acquire()print('{} 拿到了面'.format(scientist))print('{} 吃到了面'.format(scientist))noodle_lock.release()print('{} 放下了面'.format(scientist))fork_lock.release()print('{} 放下了叉子'.format(scientist))scientist_list1 = ['霍金','居里夫人']scientist_list2 = ['爱因斯坦','富兰克林']noodle_lock  = Lock()fork_lock = Lock()for i in scientist_list1:t = Thread(target=eatNoodles_1, args=(noodle_lock, fork_lock, i))t.start()for i in scientist_list2:t = Thread(target=eatNoodles_2, args=(noodle_lock, fork_lock, i))t.start()

import timefrom threading import Threadfrom threading import RLockdef eatNoodles_1(noodle_lock, fork_lock, scientist):noodle_lock.acquire()print('{} 拿到了面'.format(scientist))fork_lock.acquire()print('{} 拿到了叉子'.format(scientist))time.sleep(1)print('{} 吃到了面'.format(scientist))fork_lock.release()noodle_lock.release()print('{} 放下了面'.format(scientist))print('{} 放下了叉子'.format(scientist))def eatNoodles_2(noodle_lock, fork_lock, scientist):fork_lock.acquire()print('{} 拿到了叉子'.format(scientist))noodle_lock.acquire()print('{} 拿到了面'.format(scientist))print('{} 吃到了面'.format(scientist))noodle_lock.release()print('{} 放下了面'.format(scientist))fork_lock.release()print('{} 放下了叉子'.format(scientist))scientist_list1 = ['霍金','居里夫人']scientist_list2 = ['爱因斯坦','富兰克林']noodle_lock=fork_lock = RLock()for i in scientist_list1:t = Thread(target=eatNoodles_1, args=(noodle_lock, fork_lock, i))t.start()for i in scientist_list2:t = Thread(target=eatNoodles_2, args=(noodle_lock, fork_lock, i))t.start()

import threadingimport time# 生产者def produce(con):# 锁定线程global numcon.acquire()print("工厂开始生产……")while True:num += 1print("已生产商品数量：{}".format(num))time.sleep(1)if num >= 5:print("商品数量达到5件，仓库饱满，停止生产……")con.notify()  # 唤醒消费者con.wait()# 生产者自身陷入沉睡# 释放锁con.release()# 消费者def consumer(con):con.acquire()global numprint("消费者开始消费……")while True:num -= 1print("剩余商品数量：{}".format(num))time.sleep(2)if num <= 0:print("库存为0，通知工厂开始生产……")con.notify()  # 唤醒生产者线程con.wait()    # 消费者自身陷入沉睡con.release()con = threading.Condition()num = 0p = threading.Thread(target=produce , args=(con ,))c = threading.Thread(target=consumer , args=(con ,))p.start()c.start()

from threading import Threadimport timeimport randomdef fun(i):print('{}号顾客上座，开始吃饭'.format(i))time.sleep(random.random())print('{}号顾客吃完饭了，离座'.format(i))if __name__=='__main__':for i in range(20):p = Thread(target=fun, args=(i,))p.start()

from threading import Threadimport timeimport randomfrom threading import Semaphoredef fun(i , sem):sem.acquire()print('{}号顾客上座，开始吃饭'.format(i))time.sleep(random.random())print('{}号顾客吃完饭了，离座'.format(i))sem.release()if __name__=='__main__':sem = Semaphore(3)for i in range(10):p = Thread(target=fun, args=(i,sem))p.start()

from threading import Event, Threadimport timefrom datetime import datetimedef func(e):print('子线程：开始运行……')while True:print('子线程：现在事件秒数是{}'.format(datetime.now().second))e.wait()  # 阻塞等待信号  这里插入了一个Flag  默认为 Falsetime.sleep(1)e = Event()p = Thread(target=func, args=(e,))p.daemon=Truep.start()for i in range(10):s = int(str(datetime.now().second)[-1])#获取当前秒数的个位数if s < 5:print('子线程线入阻塞状态')e.clear()  # 使插入的flag为False 线程线入阻塞状态else:print('子线程取消阻塞状态')e.set()  # 线程线入非阻塞状态time.sleep(1)e.set()print("主线程运行结束……")

import threadingimport timedef sayTime(name):print('你好，{}为您报时，现在时间是：{}'.format(name , time.ctime()))if __name__ == "__main__":timer = threading.Timer(2.0, sayTime, ["Jane"])timer.start()输出结果：你好，Jane为您报时，现在时间是：Thu Dec  6 15:03:41 2018如果要每个多长时间执行一次：import threadingimport timedef sayTime(name):print('你好，{}为您报时，现在时间是：{}'.format(name , time.ctime()))global timertimer = threading.Timer(3.0, sayTime, [name])timer.start()if __name__ == "__main__":timer = threading.Timer(2.0, sayTime, ["Jane"])timer.start()

import queueimport threadingdef fun():while True:try:data = q.get(block = True, timeout = 1) #不设置阻塞的话会一直去尝试获取资源except queue.Empty:print(' {}结束……'.format(threading.current_thread().name))breakprint(' {}取得数据：{}'.format(threading.current_thread().name , data))q.task_done()print(' {}结束……'.format(threading.current_thread().name))print("主线程开始运行……")q = queue.Queue(5)#往队列里面放5个数for i in range(5):q.put(i)for i in range(0, 3):t = threading.Thread(target=fun , name='线程'+str(i))t.start()q.join() #等待所有的队列资源都用完print("主线程结束运行……")

from concurrent.futures import ThreadPoolExecutorimport timedef func(n):time.sleep(2)print(n)return n*nt = ThreadPoolExecutor(max_workers=5) # 最好不要超过CPU核数的5倍t_lst = []for i in range(20):r = t.submit(func , 1)#执行任务，传递参数t_lst.append(r.result())#获取任务返回结果t.shutdown()#相当于close() + join()print(t_lst)print('主线程运行结束……')