注意点进程之间不共享全局变量主进程会等待子进程结束之后再结束设置守护主进程

多线程threading模块线程注意点线程之间执行是无序的主线程会等待所有的子线程执行结束在结束线程之间共享全局变量线程之间共享全局变量数据出现错误问题

多线程共享全局变量问题线程等待互斥锁

kwargs以字典形式给执行任务传参Process创建实例对象的常用方法

start()创建子进程join()等待子进程执行结束terminate()不管任务是否完成立即终止子进程

name当前进程的别名默认为Process-NN为从1开始递增的整数

代码示例

range(5):print(f{msg})time.sleep(1)def

dance(msg):for

range(5):print(f{msg})time.sleep(1)if

__name__

target为任务名创建一个sing线程,通过元组方式传参sing_obj

multiprocessing.Process(targetsing,

args(sing

target为任务名创建一个dance线程通过字段方式传参dance_obj

multiprocessing.Process(targetdance,

kwargs{msg:

启动两个线程sing_obj.start()dance_obj.start()获取进程编号

获取进程编号的目的是验证主进程与子进程的关系得知子进程是由哪个主进程创建出来的

常用操作

获取当前进程编号:os.getpid()回去当前父进程编号:os.getppid代码示例

*_*coding:utf-8

multiprocessing.current_process())#

os.getppid())if

multiprocessing.Process(targetsing)obj.start()获取进程名

*_*coding:utf-8

multiprocessing.current_process())if

__name__

multiprocessing.Process(targetsing,

nametest_dance)obj.start()进程注意点

进程之间不共享全局变量

进程是分配资源的最小单位每个进程都会有自己的独立空间创建子进程会对主进程资源进行拷贝也就是说子进程是主进程的一个副本之所以进程之间不共享全局变量是因为操作的不是一个进程里面的全局变量只不过不同进程里面的全局变量名字相同而已代码示例

*_*coding:utf-8

multiprocessing.Process(targetmy_read)write_obj

multiprocessing.Process(targetmy_write)#

保证全局变量数据被写入time.sleep(1)read_obj.start()主进程会等待子进程结束之后再结束

代码示例

range(5):time.sleep(0.3)print(func())if

__name__

multiprocessing.Process(targetfunc)obj.start()print(main)exit(0)设置守护主进程

设置守护主进程的目的是主进程退出子进程销毁不让主进程等待子进程去执行设置守护主进程方式子进程对象.daemontrue销毁子进程方式子进程对象.terminate()注意需要在子进程start之前设置

多线程

True:print(f{msg})time.sleep(1)def

dance(msg):while

True:print(f{msg})time.sleep(1)if

__name__

创建一个sing线程,通过元组方式传参sing_thread_obj

args(sing

创建一个dance线程通过字段方式传参dance_thread_obj

kwargs{msg:

启动两个线程sing_thread_obj.start()dance_thread_obj.start()线程注意点

代码示例

sleep的时候CPU是空闲的所有创建出来的线程都在等待CPU的执行time.sleep(0.3)#

实际执行线程位置print(threading.current_thread())if

__name__

threading.Thread(targetfunc)my_func.start()主线程会等待所有的子线程执行结束在结束

未设置守护线程代码示例

range(5):time.sleep(0.2)print(func)if

__name__

threading.Thread(targetfunc)obj.start()time.sleep(0.5)print(main

over)设置守护线程

daemonTrue)方式二线程对象.setDaemon(True)

代码示例

range(5):time.sleep(0.2)print(func)if

__name__

设置守护线程方式二obj.setDaemon(True)obj.start()time.sleep(0.5)print(main

over)线程之间共享全局变量

range(5):g_num.append(i)print(my_write:

g_num)if

threading.Thread(targetmy_write)read_obj

threading.Thread(targetmy_read)write_obj.start()#

确保write先执行time.sleep(0.1)read_obj.start()print(main

finish:

threading.Thread(targetfunc1)obj2

threading.Thread(targetfunc2)obj1.start()obj2.start()print(g_num)多线程共享全局变量问题

线程等待

语法子线程.join()功能让主线程等待当前子线程执行完毕在继续向下执行代码示例

*_*coding:utf-8

threading.Thread(targetfunc1)obj2

threading.Thread(targetfunc2)obj1.start()obj1.join()obj2.start()obj2.join()print(g_num)互斥锁

对共享数据进行锁定保证同一时刻只能有一个线程去操作基本使用语法

创建锁

threading.Thread(targetfunc1)obj2

threading.Thread(targetfunc2)obj1.start()obj2.start()