day18多线程

• 每个进程默认有一个线程，其他的是子线程
• Thread类：创建线程对象：Thread(target, args,kwargs)
  • target：函数，需要在当前线程创建的子线程中去调用的函数
  • args/kwargs：调用target中函数需要的实参列表
• 开始执行子线程的任务：线程对象.start()；通过start方法在子线程中调用target对应的函数
• 一个进程中如果有多个线程，程序会在所有的线程都结束的时候才结束；发生异常崩溃指的是线程崩溃而不是进程
• 创建线程的两种方法：

from threading import Thread, currentThread, current_thread
import time
import datetime

# 方法一
def download(file_name):
    print('%s downloading....' % file_name)
    print(datetime.datetime.now())
    time.sleep(5)
    print('%s download ok' % file_name)
    print(datetime.datetime.now())


t1 = Thread(target=download, args=('复联',))
t2 = Thread(target=download, args=('007',))
t1.start()
t2.start()
print('主线程')


# 方法二
class MyThread(Thread):
    def __init__(self, name):
        super().__init__()
        self.name = name

    def run(self):  # 在子线程中执行的方法
        print(current_thread().getName())

for i in range(1,6):
    t = MyThread('线程%s' % i)
    t.start()

• 子线程崩溃不会影响主线程或者其他子线程的执行
• join()方法：如果希望某个任务是在某个线程结束后才执行，那就将这个任务的代码放在对应线程对象调用join方法的后面
• 线程锁：from threading import Lock;当多个线程对同一个数据进行操作时，需要使用线程锁来保证这个数据的安全

from threading import Lock

mutex = Lock()

mutex.acquire()  # 加锁
mutex.release()  # 解锁

# 1.保证每个数据对应一个锁对象
# 2.操作数据前加锁，数据操作完成后释放锁