python多线程调度_python 一个简单的线程调度
一、基本概念
线程
在一个进程内部要同时运行多个子任务,我们将进程内的子任务称为线程,一个进程内至少包括一个线程,线程是最小的执行单元,没有自己独立的堆栈
线程调度
使用算法是线程按一定的顺序执行
二、完成简单的线程调度
题目要求
有两个线程分别输出0,2,4,6,8和1,3,5,7,9,编写程序使得输出顺序是0,1,2,3,4,5,6,7,8,9
源代码
import threading
import time
cond = threading.Condition()
def func1(num):
print("子线程(%s)开始执行" % (threading.current_thread().name))
with cond:
for i in range(num,10,2):
time.sleep(0.5)
print(i)
cond.wait()#等待,当前线程停止,其他线程执行
cond.notify()
print("子线程(%s)结束执行" % (threading.current_thread().name))
def func2(num):
print("子线程(%s)开始执行" % (threading.current_thread().name))
with cond:
for i in range(num, 10, 2):
time.sleep(0.5)
print(i)
cond.notify()#通知上面其他的线程自己已经执行完毕,然后自己等待
cond.wait()#自己等待
print("子线程(%s)结束执行" % (threading.current_thread().name))
if __name__ == __main__:
print("主线程(%s)开始执行" % (threading.current_thread().name))
#主线程
t1 = threading.Thread(target=func1,name=线程1,args=(0,))
t2 = threading.Thread(target=func2, name=线程2,args=(1,))
t1.start()
t2.start()
print("主线程(%s)结束执行" % (threading.current_thread().name))
一、基本概念 线程 在一个进程内部要同时运行多个子任务,我们将进程内的子任务称为线程,一个进程内至少包括一个线程,线程是最小的执行单元,没有自己独立的堆栈 线程调度 使用算法是线程按一定的顺序执行 二、完成简单的线程调度 题目要求 有两个线程分别输出0,2,4,6,8和1,3,5,7,9,编写程序使得输出顺序是0,1,2,3,4,5,6,7,8,9 源代码 import threading import time cond = threading.Condition() def func1(num): print("子线程(%s)开始执行" % (threading.current_thread().name)) with cond: for i in range(num,10,2): time.sleep(0.5) print(i) cond.wait()#等待,当前线程停止,其他线程执行 cond.notify() print("子线程(%s)结束执行" % (threading.current_thread().name)) def func2(num): print("子线程(%s)开始执行" % (threading.current_thread().name)) with cond: for i in range(num, 10, 2): time.sleep(0.5) print(i) cond.notify()#通知上面其他的线程自己已经执行完毕,然后自己等待 cond.wait()#自己等待 print("子线程(%s)结束执行" % (threading.current_thread().name)) if __name__ == __main__: print("主线程(%s)开始执行" % (threading.current_thread().name)) #主线程 t1 = threading.Thread(target=func1,name=线程1,args=(0,)) t2 = threading.Thread(target=func2, name=线程2,args=(1,)) t1.start() t2.start() print("主线程(%s)结束执行" % (threading.current_thread().name))