python--多任务线程-白红宇

print方法的注意点

def print(value, ..., end,..., flush)复制代码

end 结尾符号,默认"\n"

flush 是否刷新缓冲区数据到控制台,python的print，默认是将数据写入缓冲区，缓冲区有默认大小，只有数据大小超出缓冲区限制或者遇到换行符或者手动设置刷新(flush=True)才会写入到控制台

import timedef main():    for i in range(10):        print("*",end="")        time.sleep(1)if __name__ == '__main__':    main()复制代码

并发和并行

并发：假的的多任务，看上去同时运行，实际同一时刻只有一个任务在执行，cpu核心数小于任务数量

并行：真的多任务，cpu核心数大于等于任务数量

多线程的基本实现

为了实现多任务，可以将任务放入子线程去执行

任务放在一个函数中

def func():        pass复制代码

创建一个线程类的实例对象 t1 = threading.Thread(target=fun)

创建线程，并执行任务函数 t1.start()

主线程会等待所有子线程任务结束后再结束

多线程的第二种实现

写一个类继承自threading.Thread类，并重写run()方法

class MyThread(threading.Thread):    def run(self):        """        线程的执行体        :return:        """        self.register()        for i in range(3):            time.sleep(1)            msg = "I'm" + self.name + "@" + str(i)            print(msg)        self.login()    def login(self):        print("----login---")    def register(self):        print("---register----")复制代码

如果需要在子线程执行任务，比如按照如下

t = MyThread()t.start() # 不能调用run，否在就是在主线程运行run方法复制代码

在传统的创建线程的方式中，也是如上代码一样，通过t.start()开启子线程，并在子线程内调用run方法，

t1 = threading.Thread(target=fun)t1.start()def run(self):    # 必须在创建类的实例对象时指定target    if self._target:        self._target(*self._args, **self._kwargs)复制代码

多线程修改全局变量

多个线程在操作同一个全部变量的时候，可能导致变量的值和预期的不一样，引发线程安全问题解决办法：引入互斥锁，在关键代码的前后加入锁，保证操作变量的原子性（操作变量时代码完整执行，期间不能切换到别的线程去执行修改变量的操作）

死锁

线程间的资源竞争，多个线程中存在多把，都在等待对方先释放锁，这样就导致了死锁问题

解决办法：

1. 银行家算法2. 添加超时3. 不用使用多把锁复制代码