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学习：配置日志的几种方式 Python开发

    Python学习：配置日志的几种方式

    作为开发者，我们可以通过以下3种方式来配置logging: 1）使用Python代码显式的创建loggers, handlers和formatters并分别调用它们的配置函数；2）创建一个日志配置文件，然后使用fileConfig()函数来读取该文件的内容；3）创建一个包含配置信息的dict，然后把它传递个dictConfig()函数； 需要说明的是，log…

    2023年4月2日
    00

  • Python中 re.compile 函数的使用

    以下介绍在python的re模块中怎样应用正则表达式 1. 使用re.compile re模块中包含一个重要函数是compile(pattern [, flags]) ，该函数根据包含的正则表达式的字符串创建模式对象。 可以实现更有效率的匹配。在直接使用字符串表示的正则表达式进行search,match和findall操作时，python会将字符串转换为正则…

    Python开发 2023年3月31日
    00

  • python教程：一个 list 使用 for 遍历，边循环边删除的问题

    今天由于要对一个 list 数据类型写一个循环删除的程序（这是小编第一次对于 list 操作），但发现一个奇异问题，来，我们来看看代码跟效果： # 初始化一个 list 列表，为了下边的方便比较，我就使用跟 list 索引来做 list 的元素 datas = [0,1,2,3,4] # 打印元素组，方便比较 print(datas) #使用 for 遍历 …

    Python开发 2023年4月2日
    00

  • Python中5大模块的使用教程（collections模块、time时间模块、random模块、os模块、sys模块）

    1. 模块的简单认识 定义: 模块就是我们把装有特定功能的代码进行归类的结果. 从代码编写的单位来看我们的程序,从小到大的顺序: 一条代码 < 语句块 < 代码块(函数,类) < 模块.我们⽬目前写的所有的py文件都是模块.引入模块的方式: import 模块 from xxx import 模块 2. collections模块 coll…

    Python开发 2023年4月2日
    00

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

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

    Python开发 2023年4月2日
    00

  • Python教程：OS与sys模块用法教程

    一、Python os模块 包含普遍的操作系统功能，如果你希望你的程序能够与平台无关的话，这个模块是尤为重要的。 1、os.access() 查看文件是否有指定权限，有则返回True否则返回flase os.access(path, mode) path:指定文件路径 mode:参数有F_OK(是否存在),R_OK(可读),W_OK(可写),X_OK(可执行…

    Python开发 2023年3月31日
    00

  • python中shutil和shutil库的用法

    一、shutil目录和文件操作 Python shutil库提供了对文件和目录复制、移动、删除、压缩、解压等操作。 1. 复制文件或目录 shutil.copy(src, dst)：复制文件或目录 shutil.copyfile(src, dst)：复制文件，src和dst只能是文件 shutil.copytree(src, dst, dirs_exist_…

    python 2023年4月18日
    00

  • Python3教程：多线程的使用教程

    一、简介 Python中使用线程有两种方式：函数或者用类来包装线程对象。 函数式：调用 _thread 模块中的start_new_thread()函数来产生新线程。语法如下: 参数说明: function – 线程函数。 args – 传递给线程函数的参数,他必须是个tuple类型。 kwargs – 可选参数。 实例： import _thread im…

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