1. Python技术站首页
  2. Python开发

Python教程：如何创建多线程？

• Python开发

一、python线程的模块

1.thread和threading模块

  • thread模块提供了基本的线程和锁的支持
  • threading提供了更高级别、功能更强的线程管理的功能。

2. Queue模块

Queue模块允许用户创建一个可以用于多个线程之间共享数据的队列数据结构。

3.注意模块的选择

  • 避免使用thread模块
  • 因为更高级别的threading模块更为先进，对线程的支持更为完善
  • 而且使用thread模块里的属性有可能会与threading出现冲突；
  • 其次低级别的thread模块的同步原语很少(实际上只有一个)，而threading模块则有很多；
  • 再者，thread模块中当主线程结束时，所有的线程都会被强制结束掉，没有警告也不会有正常的清除工作，至少threading模块能确保重要的子线程退出后进程才退出。

注意：thread模块不支持守护线程，当主线程退出时，所有的子线程不论它们是否还在工作，都会被强行退出。而threading模块支持守护线程，守护线程一般是一个等待客户请求的服务器，如果没有客户提出请求它就在那等着，如果设定一个线程为守护线程，就表示这个线程是不重要的，在进程退出的时候，不用等待这个线程退出。

二、Threading模块

multiprocess模块的完全模仿了threading模块的接口，二者在使用层面，有很大的相似性，因而不再详细介绍

三、通过Threading.Thread类来创建线程

1 .创建线程的方式一

直接通过Threading.Thread来创建

from threading import Thread
import time

def task(name):
    print(f'子线程{name} is running')
    time.sleep(1)
    print(f'子线程{name} is end')
    
# 因为创建线程不需要重新开辟内存空间，所以不用写main，创建线程只是单独把启动线程函数里面的代码拿出来用
t = Thread(target=task,args=('小明',))
t.start()
print('主线程结束')

2 创建线程的方式二

通过自定义类来继承Thread类来创建线程

from threading import Thread
import time

class MyDic(Thread,name):
    def __init__(self,name)
    	super().__init__()
        self.name = name
    
    def run(self):
        print(f'子线程{name} is running')
        time.sleep(1)
        print(f'子线程{name} is end')

       
t = Mydic('小明')
t.start()
print('主进程结束')

四、多线程和多进程的比较

1 pid的比较

'''
学习中遇到问题没人解答？小编创建了一个Python学习交流QQ群：711312441
寻找有志同道合的小伙伴，互帮互助,群里还有不错的视频学习教程和PDF电子书！
'''
from threading import Thread
from multiprocessing import  Process
import time
import os

def task(name):
    print(f'子线程{name} is running')
    time.sleep(1)
    print(f'子线程{name} is end')
    print(f'子线程{name}的pid：{os.getpid()}')


def task1(name):
    print(f'进程{name} is running')
    time.sleep(1)
    print(f'进程{name} is end')
    print(f'进程的{name}pid：{os.getpid()}')


if __name__ == '__main__':
    # part1:在主进程下开启多个线程,每个线程都跟主进程的pid一样
    t = Thread(target=task, args=('小明',))
    t.start()
    t.join()
    print(f'主线程的pid：{os.getpid()}')

    
    # 开多个进程，每一个进程的pid号都不一样
    p = Process(target=task1,args=('zhangsan',))
    p1 = Process(target=task1,args=('zhang',))
    p.start()
    p1.start()
    p.join()
    p1.join()
    print(f'主进程的pid：{os.getpid()}')

2 线程和进程开启效率的较量

from threading import Thread
from multiprocessing import Process
import time

def task(name):
    print(f'{name} is running')
    time.sleep(2)
    print(f'{name} is end')


if __name__ == '__main__':
    t = Thread(target=task,args=('子线程',))
    p = Process(target=task,args=('子进程',))
    t.start()
    # p.start()
    print('主')

（1.开启线程的速度:

子线程 is running

主

子线程 is end

（2.开启进程的速度：

主

子进程 is running

子进程 is end

3 内存数据共享问题

from threading  import Thread
from multiprocessing import  Process
import time,os

x = 100
def task():
    global x
    x = 50 # 此时线程是在拿全局的x的值
    print(os.getpid()) # 因为开启线程是不需要操作系统给线程分配内存空间的，所以线程用的是它当前所在的进程的进程号


if __name__ == '__main__':
    # 线程
    t = Thread(target=task)
    t.start()
    time.sleep(2)
    print(x) # 50，这里说明线程他是共享他所在进程下的所有资源，对资源进行一系列的操作
    print(os.getpid())

    # 进程
   # p = Process(target=task)
   # p.start() 
   # print(x) # 这里的x还是主进程的x 100

五、Thread类的其他方法

Thread实例对象的方法：

  • isAlive()：返回线程是否活动的。
  • getName()：返回线程名。
  • setName()：设置线程名。

threading模块提供的一些方法：

  • threading.currentThread()：返回当前的线程变量。
  • threading.enumerate()：返回一个包含正在运行的线程的list。正在运行指线程启动后、结束前，不包括启动前和终止后的线程。
  • threading.activeCount()：返回正在运行的线程数量，与len(threading.enumerate())有相同的结果。

1 代码实例

from threading import Thread,currentThread,enumerate,activeCount
import time

def task():
    print('子线程 start')
    time.sleep(2)
    print('子线程 end')
    print(enumerate())# 返回一个包含正在运行的线程的list。正在运行指线程启动后、结束前，不包括启动前和终止后的线程。
    print(currentThread(),'子线程') # 返回当前的线程变量
    print(activeCount())

if __name__ == '__main__':
   t1 = Thread(target=task)
   t2 = Thread(target=task)
   t1.start()
   t2.start()
   t2.setName('小明')
   print(t2.getName()) # 得到t2的线程名字，是我们设置好的小明
   print(t1.getName()) # 得到t1的线程名子 Thread-1
   print(t1.is_alive()) # True

2 join方法

'''
学习中遇到问题没人解答？小编创建了一个Python学习交流QQ群：711312441
寻找有志同道合的小伙伴，互帮互助,群里还有不错的视频学习教程和PDF电子书！
'''
from threading import Thread
import time
def task():
    print('子线程 start')
    time.sleep(2)
    print('子线程 end')

t = Thread(target=task)
t.start()
t.join() # 等待子线程运行结束
print('主线程')

六、多线程实现socket

1 服务端

import socket
from threading import Thread

socket = socket.socket(socket.AF_INET,socket.SOCK_STREAM)
socket.bind(('192.168.11.78',8004))
socket.listen(5)

def action(conn,addr):
    while True:
        try:

            msg = (conn.recv(1024)).decode('utf8').upper()
            print(f'客户端{addr}发送的数据为：{msg.lower()}')
            print(f'向客户端{addr}发送数据为',msg)
            conn.send(msg.encode('utf8'))
        except:
            break


if __name__ == '__main__':
    print('等待客户端连接:')
    while True:
        try:
            conn,addr = socket.accept()
            print(f'客户端已连接{addr}')
            t = Thread(target=action,args=(conn,addr))
            t.start()
        except:
            print(f'客户端{addr}断开连接 ！！')
            break

2 客户端

import  socket

client = socket.socket()
client.connect(('192.168.11.78',8004))

while True:
    msg = input('输入：')
    if msg == 'q':
        break
    client.send(msg.encode('utf8'))
    flag = client.recv(1024)
    print('接收服务端的数据为：',flag.decode('utf8'))

本站文章如无特殊说明，均为本站原创，如若转载，请注明出处：Python教程：如何创建多线程？ - Python技术站

赞 (0)
0 0 打赏 微信扫一扫 微信扫一扫 支付宝扫一扫 支付宝扫一扫
上一篇 2023年4月2日 下午4:07
下一篇 2023年4月2日

相关文章

  • Python中的交互库-os库

    一.介绍 os库是与操作系统相关的库，它提供了通用的基本的操作系统交互功能。os库是Python的标准库之一，它里面包含几百个处理函数，能够处理与操作系统相关的功能，包括路径操作、进程管理、环境参数设置等几类功能。其中路径操作是利用os.path子库，它用于处理文件以及目录的路径，并获得相关的信息；进程管理指启动系统中的其它程序的功能；环境参数指获得系统软硬…

    python 2023年5月10日
    00

  • 43道Python经典案例题（有答案）

    1.有四个数字：1、2、3、4，能组成多少个互不相同且无重复数字的三位数？各是多少？ for x in range(0,5): for y in range(0,5): for z in range(0,5): if x != y and y != z and z != x: print(x,y,z) 2.题目：企业发放的奖金根据利润提成。 解析： 利润（I…

    Python开发 2023年4月2日
    00

  • Python教程：几个常用的内置函数

    匿名函数(lambda表达式) 在Python中，函数可以算的上是“一等公民”了，我们先回顾下函数的优点： 减少代码重复量 模块化代码 但是我们有没有想过，如果我们需要一个函数，比较简短，而且只需要使用一次（无需重复调用），那还需要定义一个有名字的函数么？ 答案是否定的，这里我们就可以使用匿名函数来实现这样的功能。 我们先看看求一个数的平方，我们定义个函数怎…

    Python开发 2023年4月2日
    00

  • Python学习：构造函数与析构函数

    1.构造函数： __init__(self)， 这个方法就是构造函数，在实例化的时候自动调用。 所有如果这个函数内有打印的方法，当实例出来的时候会打印里面的信息。 __init__方法的第一个参数永远都是self，表示创建实例本身，在__init__方法内部，可以把各种属性绑定到self，因为self指向创建的实例本身。 有了__init__方法，在创建实例…

    Python开发 2023年4月2日
    00

  • Python教程：list.sort()和函数sorted(list)

    1.sort()是列表的方法,修改原列表使得它按照大小排序,没有返回值,返回None In [90]: x = [4, 6, 2, 1, 7, 9] In [91]: x.sort() In [92]: x Out[92]: [1, 2, 4, 6, 7, 9] In [98]: aa = x.sort() In [99]: aa # 返回None 2.so…

    Python开发 2023年4月2日
    00

  • Python类的封装教程

    一、什么是封装 封装的本身意思其实就和闭包函数一样，就是把一个函数和变量全都包在一起，但其实这样的说法不是很具体，就是一种很片面的解释 二、为什么要封装 封装数据的主要原因是：保护隐私 封装方法的主要原因是：隔离复杂度（快门就是傻瓜相机为傻瓜们提供的方法，该方法将内部复杂的照相功能都隐藏起来了，只提供了一个快门键，就可以直接拍照） 提示：在编程语言里，对外提…

    Python开发 2023年3月31日
    00

  • Python中的异常处理总结

    1.异常分类 错误Error： 原因 示例 笔误 像变量名写错，造成的语法错误 逻辑错误 算法写错了，例如原本逻辑是求和，但写成了乘积 函数或者类使用错误 这类也归为逻辑错误 写代码时，错误是可以避免的。 异常Exception 有时候程序写的没有问题，也没有语法错误，但在某些情况下依然出现一些意外，导致程序无法正常执行，就是通常所说的异常。 例如open函…

    Python开发 2023年3月31日
    00

  • python中5个带key的内置函数

    1.max取最大值函数 max() 方法返回给定参数的最大值，参数可以为序列。 lis = [1,2,3,-4] print(max(lis)) #返回lis列表中的最大值 ”’结果： 3 ”’ print(max(lis,key=abs)) #key参数指向绝对值函数，返回的结果是-4 2.min取最小值函数 min() 方法返回给定参数的最小值，参数…

    Python开发 2023年4月2日
    00
合作推广
合作推广
分享本页
返回顶部