python中线程和进程的简单了解

时间：2021-07-25 01:55:05

python中线程和进程的简单了解

一、操作系统、应用程序

　　1.硬件：硬盘、cpu、主板、显卡........

　　2.装系统（本身也是一个软件）：

　　　　系统就是一个由程序员写出来的软件，该软件用于控制计算机得硬盘，让他们之间进行互相配合。

　　3.安装软件：各种应用程序

二、并发和并行

　　并发：伪，由于执行速度特别快，人感觉不到停顿

　　并行：真，创建多个对象同时操作

三、线程、进程

　　1.单进程、单线程的应用程序

　　　　print("asd")

　　2.到底什么是线程、进程

　　　　python中没有这两个，是python调用的操作系统的线程和进程

　　3.单进程、多线程的应用程序

python中线程和进程的简单了解
import threading　　　　#两个进程

print("start")

def func(arg):

    print(arg)

t = threading.Thread(target=func,args=("......",))

t.start()

print("end")

# start

# ......

# end
python中线程和进程的简单了解
import threading

class MyThread(threading.Thread):

    def run(self):

       print(11111,self._args,self._kwargs)    #********

t1 = MyThread(args=(11,))

t1.start()

print("end")

# 11111 (11,) {}

# end
python中线程和进程的简单了解

python多线程情况下：

　　计算密集型操作：效率低（GIL锁）

　　IO操作：效率高

python多进程的情况下：

　　计算密集型：效率高（浪费资源）

　　IO操作：效率高（浪费资源）

在使用时：

　　IO密集型用多线程：文件、输入、输出、socket网络通信

　　计算密集型用多进程

四、python中线程和进程（GIL锁）

　　GIL锁，全局解释器锁，用于限制一个进程中同一时刻只有一个线程被cpu调度。

　　扩展：默认GIL锁在执行100个cup指令（过期时间）

setDaemon(True) 若为Ture 则会直接运行主线程,不用等待
 import  threading

 import time

 def func(a):

     time.sleep(2)

     print(a)

 s1=threading.Thread(target=func,args=(1,))

 s1.setDaemon(True)

 s1.start()

 s2=threading.Thread(target=func,args=(2,))

 s2.setDaemon(False)#只要两个

 s2.start()

join的使用

 join是限制主线程等待子线程的时间，等够了就不再等子线程执行结束，主线程接着执行，没等够主线程就会停下等待，并不是时间到了程序停止的意思 
 import time#让主线程等待

 import  threading

 def func(a):

     time.sleep(2)

     print(a)

 print("创建t1")

 t1=threading.Thread(target=func,args=(1,))

 t1.start()

 t1.join(1)

 print("创建t2")

 t2=threading.Thread(target=func,args=(2,))

 t2.start()

 t2.join(1)

 print(123)

获取名字

 import threading#或取名字

 def func(arg):

     t=threading.current_thread()#创建对象

     name=t.getName()#直接查找名字哦

     print(name,arg)

 t1=threading.Thread(target=func,args=(1,))

 t1.setName("张庆")

 t1.start()

 print(123)

加锁:

 import  threading

 import  time

 lock = threading.RLock()

 n = 10

 def task(i):

     print('这段代码不加锁',i)

     lock.acquire() # 加锁，此区域的代码同一时刻只能有一个线程执行

     #这题区域分为加锁前和后 先按顺序执行加锁前面的代码,一旦发现加锁

     #就直接执行这一个线程的代码>>>执行prient

     #执行后执行加锁后面的代码,需要解锁 才可以实现

     #解锁后也是根据这一课一线程的代码一步一步解锁

     #

     global n

     print('当前线程',i,'读取到的n值为：',n)

     n = i

     time.sleep(1)

     print('当前线程',i,'修改n值为：',n)

     lock.release(),

 for i in range(10):

     t = threading.Thread(target=task,args=(i,))

     t.start()

相关文章