英铭网站建设网站推广广告

一、多线程  threading模块

# 线程和进程

'''

1.线程是最小的调度单位

2.进程是最小的管理单元

3.一个进程必须至少一个线程

4.没有线程，进程也就不复存在

'''

 

 

# 多线程特点：

# python线程特点

#线程的并发是利用cpu上下文的切换（是并发，不是并行）

#多线程执行的顺序是无序的

# def test1(n):
#     time.sleep(1)
#     print('task', n)
#
# # t1 = threading.Thread(target=test1,args=(1,))
# # t1.start()
#
# for i in range(10):
#     t = threading.Thread(target=test1,args=('t-%s' % i,))#args:传递的参数！
#     t.start()

#多线程共享全局变量，但是在使用之前要声名

 

# g = 0
# def test1():
#     global g
#     for i in range(10):
#         g += 1
#     print(g)
# def test2():
#     global g
#     for i in range(10):
#         g += 1
#     print(g)
#
# t1 = threading.Thread(target=test1)  #target=test1:建立线程时的调用对象是test1
# t2 = threading.Thread(target=test2)
# t1.start()
# t2.start()

 

#线程是继承在进程里的，没有进程就没有线程

#GIL全局解释器锁：

当运行如下代码时，运行结果会出现错误，

import threading
lock = threading.Lock()
global_num = 0
def test1():global global_numfor i in range(1000000):global_num += 1def test2():global global_numfor i in range(1000000):global_num += 1t1 = threading.Thread(target=test1)
t2 = threading.Thread(target=test2)
t1.start()
t2.start()
t1.join()
t2.join()
print(global_num)

这是因为：

1，主线程运行时间太短，调用函数的t1,t2两个线程，还没有运行完，主线程就已经运行结束了

2.有GIL全局解释器存在的原因，导致错误

 

 

# lock = threading.Lock()
# global_num = 0
# def test1():
#     global global_num
#     lock.acquire()
#     for i in range(1000000):
#         global_num += 1
#     lock.release()
# def test2():
#     global global_num
#     lock.acquire()
#     for i in range(1000000):
#         global_num += 1
#     lock.release()
# t1 = threading.Thread(target=test1)
# t2 = threading.Thread(target=test2)
# t1.start()
# t2.start()
# t1.join()
# t2.join()
# print(global_num)

解决的方法：

1.要使用join方法，以保证各个进程运行完

2.申请一个用户锁，将代码锁定，等到锁定的代码执行完毕之后再释放GIL全局解释器锁

#在IO密集型的代码里，适合用多线程

 

二、多进程  multiprocessing模块

#一个程序运行起来之后，代码+用到的资源称之为进程，它是操作系统分配资源的基本单位，不仅可以通过线程完成多任务，进程也是可以的

#进程之间是相互独立的

#cpu密集的时候适合用多进程

import multiprocessing
import time
# g = 0
# def test1(n):
#     time.sleep(50)
#     global g
#     for i in range(10):
#         g += 1
#     print(g)
# def test2(n):
#     time.sleep(50)
#     global g
#     for i in range(10):
#         g += 1
#     print(g)
# # test1(1)
# # test2(2)
# if __name__ == '__main__':
#     p1 = multiprocessing.Process(target=test1,args=(1,))
#     p2 = multiprocessing.Process(target=test2,args=(2,))
#     p1.start()
#     p2.start()#进程池
# import multiprocessing
# from multiprocessing import Pool
# import time
# import threading
# g_num = 0
# def test1(n):
#     for i in range(n):
#         time.sleep(1)
#         print('test1', i)
#
# def test2(n):
#     for i in range(n):
#         time.sleep(1)
#         print('test2', i)
# def test3(n):
#     for i in range(n):
#         time.sleep(1)
#         print('test3', i)
#
# def test4(n):
#     for i in range(n):
#         time.sleep(1)
#         print('test4', i)
#
# if __name__ == '__main__':
#     pool = Pool(1)#把进程声明出来，括号里不写东西说明无限制，如果写数字，就是最大的进程数
#     pool.apply_async(test1,(10,))#用pool去调用函数test1，参数为10格式为(10,)
#     pool.apply_async(test2,(10,))#用pool去调用函数test2，参数为10格式为(10,)
#     pool.apply_async(test3,(10,))#用pool去调用函数test3，参数为10格式为(10,)
#     pool.apply_async(test4,(10,))#用pool去调用函数test4，参数为10格式为(10,)
#     pool.close()  # close必须在join的前面
#     pool.join()