Python并发编程 04 进程与线程基础

文章目录

  • 一、操作系统简介
  • 二、进程
  • 三、线程
  • 四、线程的调用
    • 1、示例
    • 2、join方法
    • 3、setDaemon方法
    • 4、继承式调用（不推荐）
    • 5、其他方法

一、操作系统简介

①操作系统是一个用来协调、管理和控制计算机硬件和软件资源的系统程序，它位于硬件和应用程序之间。它可以向上给程序员提供管理硬件的接口，方便编写应用程序。
②操作系统内核是一个管理和控制程序，负责管理计算机所有物理资源，其中包括：文件系统、内存管理、设备管理和进程管理。

二、进程

①进程是一个程序在一个数据集上的一次动态执行过程。
②进程一般由程序、数据集、进程控制块三部分组成。
③进程控制块是用来记录进程的外部特征，描述进程的执行变化过程，系统可以利用它来控制和管理进程。它是系统感知进程存在的唯一标识。

三、线程

①进程是最小的资源单位。线程是最小执行单元。进程是线程的容器，线程是进程的一个实体。
②一个运行的程序至少有一个进程，一个进程至少有一个线程。
③进程在执行过程中拥有独立的内存单元，而多个线程共享其内存。
④线程在执行中与进程还是有区别的。每个独立的线程有一个程序运行的入口、顺序执行序列和程序出口。但是线程不能独立于进程存在。
⑤一个线程可以创建和撤销另一个线程。
⑥同一个进程中的多个线程之间可以并发执行。

四、线程的调用

1、示例

import threading
import time

def Hi(num):
    print("hello %d\n" %num,end='')
    time.sleep(3)

if __name__ == "__main__":
    t1 = threading.Thread(target=Hi, args=(10,)) # 主线程创建了一个子线程对象
    t1.start()  # 子线程t1运行函数H1

    t2 = threading.Thread(target=Hi, args=(9,)) # 主线程创建了一个子线程对象
    t2.start()  # 子线程t2运行函数H1

    print("ending",end='')

**上述代码分析：**主线程按照顺序从上到下顺序执行，主线程开设子线程后，与子线程并发运行。所以上述代码会先输出：
  hello 10
  hello 9
  ending
 然后等待三秒，程序运行结束。

2、join方法

join方法：在子进程完成运行之前，这个子进程的父进程一直被阻塞。

import threading
import time

def music():
    print("begin to listen %s\n" %time.strftime("%X"),end="")
    time.sleep(3)
    print("stop to listen %s\n" %time.strftime("%X"),end="")

def game():
    print("begin to game %s\n" %time.strftime("%X"),end="")
    time.sleep(6)
    print("stop to game %s\n" %time.strftime("%X"),end="")

if __name__ == "__main__":
    t1 = threading.Thread(target=music) # 主线程创建了一个子线程对象
    t1.start()  # 子线程t1运行函数H1

    t2 = threading.Thread(target=game) # 主线程创建了一个子线程对象
    t2.start()  # 子线程t2运行函数H1
    t1.join()   # 阻塞主线程，主线程会等待t1线程执行完毕后再继续往下执行

    print("ending %s\n" %time.strftime("%X"),end='')
    
'''
begin to listen 15:04:40
begin to game 15:04:40
stop to listen 15:04:43
ending 15:04:43
stop to game 15:04:46
'''

import threading
import time


def music():
    print("begin to listen %s\n"%time.strftime("%X"),end="")
    time.sleep(5)
    print("stop to listen %s\n" % time.strftime("%X"),end="")


def game():
    time.sleep(1)
    t3=threading.Thread(target=music)
    t3.start()

    print("begin to play game %s\n"%time.strftime("%X"),end="")
    time.sleep(3)
    print("stop to play game %s\n" % time.strftime("%X"),end="")


if __name__ == '__main__':

    t1=  threading.Thread(target=music)

    t2 = threading.Thread(target=game)
    t1.start()
    t2.start()

    t1.join()
    t2.join()

    print("ending %s\n" %time.strftime("%X"),end="")

'''
begin to listen 15:29:44
begin to listen 15:29:45
begin to play game 15:29:45
stop to play game 15:29:48
stop to listen 15:29:49
ending 15:29:49
stop to listen 15:29:50
'''

import threading
import time


def music():
    print("begin to listen %s\n"%time.strftime("%X"),end="")
    time.sleep(5)
    print("stop to listen %s\n" % time.strftime("%X"),end="")


def game():
    time.sleep(1)
    t3=threading.Thread(target=music)
    t3.start()
    t3.join()

    print("begin to play game %s\n"%time.strftime("%X"),end="")
    time.sleep(3)
    print("stop to play game %s\n" % time.strftime("%X"),end="")


if __name__ == '__main__':

    t1=  threading.Thread(target=music)

    t2 = threading.Thread(target=game)
    t1.start()
    t2.start()

    t1.join()

    print("ending %s\n" %time.strftime("%X"),end="")

'''
begin to listen 15:35:54
begin to listen 15:35:55
stop to listen 15:35:59
ending 15:35:59
stop to listen 15:36:00
begin to play game 15:36:00
stop to play game 15:36:03
'''

3、setDaemon方法

setDaemon方法：将线程声明为守护线程，必须在start()方法调用之前设置，将子线程设置为守护线程后，主线程只要完成了，子线程就会和主线程一起退出。该方法基本与join方法是相反的。

import threading
from time import ctime,sleep
import time

def ListenMusic(name):
    print("Beign listening to %s %s\n" %(name,time.strftime("%X")), end="")
    sleep(3)
    print("end listening %s\n" %time.strftime("%X"), end="")

def RecordBlog(title):
    print("Begin recording the %s %s\n" %(title,time.strftime("%X")),end="")
    sleep(5)
    print("end recording %s\n" %time.strftime("%X"), end="")

threads = []

t1 = threading.Thread(target=ListenMusic, args=("水手",))
t2 = threading.Thread(target=RecordBlog, args=("python线程",))

threads.append(t1)
threads.append(t2)

if __name__ == "__main__":
    t1.setDaemon(True)

    for t in threads:
        t.start()

    print("all over %s\n" %time.strftime("%X"), end="")


'''
Beign listening to 水手 01:22:27
Begin recording the python线程 01:22:27
all over 01:22:27
end listening 01:22:30
end recording 01:22:32
'''

import threading
from time import ctime,sleep
import time

def ListenMusic(name):
    print("Beign listening to %s %s\n" %(name,time.strftime("%X")), end="")
    sleep(3)
    print("end listening %s\n" %time.strftime("%X"), end="")

def RecordBlog(title):
    print("Begin recording the %s %s\n" %(title,time.strftime("%X")),end="")
    sleep(5)
    print("end recording %s\n" %time.strftime("%X"), end="")

threads = []

t1 = threading.Thread(target=ListenMusic, args=("水手",))
t2 = threading.Thread(target=RecordBlog, args=("python线程",))

threads.append(t1)
threads.append(t2)

if __name__ == "__main__":
    t2.setDaemon(True)

    for t in threads:
        t.start()

    print("all over %s\n" %time.strftime("%X"), end="")


'''
Beign listening to 水手 01:23:23
Begin recording the python线程 01:23:23
all over 01:23:23
end listening 01:23:26
'''

4、继承式调用（不推荐）

import threading
import time

class MyThread(threading.Thread):
    def __init__(self, num):
        threading.Thread.__init__(self)
        self.num = num

    def run(self):  # # run方法是重写的方法，线程对象执行start方法要运行的该函数
        print("running on number:%s, %s\n" % (self.num, time.strftime("%X")), end="")
        time.sleep(3)
        print("结束:%s, %s\n" % (self.num,time.strftime("%X")), end="")


if __name__ == "__main__":
    t1 = MyThread(1)
    t2 = MyThread(2)
    t1.start()
    t2.start()
    print("ending %s\n" % time.strftime("%X"), end="")
    
'''
running on number:1, 22:36:46
running on number:2, 22:36:46
ending 22:36:46
结束:2, 22:36:49
结束:1, 22:36:49
'''

5、其他方法

is_alive() 返回线程是否活动的
getName() 返回线程名
setName() 设置线程名

import threading
import time

def test():
    time.sleep(2)

t1 = threading.Thread(target=test)
t1.start()
print(t1.is_alive())    # True
print(t1.getName())     # Thread-1
t1.setName("T1")
print(t1.getName())     # T1

threading模块提供的一些方法
threading.currentThread() 返回当前的线程变量

import threading
import time

def test():
    time.sleep(2)
    print(threading.currentThread())    # <Thread(Thread-1, started 16028)>

t1 = threading.Thread(target=test)
t1.start()
print(threading.currentThread())    # <_MainThread(MainThread, started 14244)>

threading.enumerate() 返回一个包含正在运行的线程的列表

import threading
import time

def test():
    time.sleep(2)

t1 = threading.Thread(target=test)
t2 = threading.Thread(target=test)
t1.start()
t2.start()

print(threading.enumerate())
# [<_MainThread(MainThread, started 26852)>, <Thread(Thread-1, started 24396)>, <Thread(Thread-2, started 15376)>]

threading.active_count() 返回正在运行的线程数量

import threading
import time

def test():
    time.sleep(2)

t1 = threading.Thread(target=test)
t2 = threading.Thread(target=test)
t1.start()
t2.start()

print(threading.active_count()) # 3

本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若转载，请注明出处：http://www.mfbz.cn/a/608310.html

如若内容造成侵权/违法违规/事实不符，请联系我们进行投诉反馈qq邮箱809451989@qq.com，一经查实，立即删除！

相关文章

【已解决】直接在远程新增文件本地再提交报Merge branch ‘master‘ of

【已解决】直接在远程新增文件本地再提交报Merge branch ‘master‘ of

【已解决】直接在远程新增文件本地再提交报Merge branch ‘master’ of … 1、问题产生背景 直接在远程仓库新建了md文件&#xff0c;本地库修改了文件已添加到暂存区之后再提交报错 2、分析 远程新建文件产生变更&#xff0c;版本号与本地拿到的不一致&#xff0c;本地再次提…
阅读更多...
Docker 安装的MySQL迁移数据库

Docker 安装的MySQL迁移数据库

1. 导出数据库 docker ps :查看数据库对应的 CONTAINER ID docker exec -it id /bin/bash : 进入到mysql的docker实例中 cd /usr/bin : 进入到bin目录 mysqldump -u root -p123456 study > /root/study_backup0509.sql :使用mysqldump备份库&#xff0c;注意密码与-p之间…
阅读更多...
PopChar for Mac v10.1激活版：特殊字符输入工具

PopChar for Mac v10.1激活版：特殊字符输入工具

PopChar for Mac是一款专为Mac用户设计的字符输入工具&#xff0c;其简单直观的功能使得查找和插入特殊字符变得轻而易举。 PopChar for Mac v10.1激活版下载 首先&#xff0c;PopChar为Mac提供了访问所有字体字符的能力&#xff0c;包括那些难以通过键盘直接输入的字符。用户只…
阅读更多...
【3dmax笔记】032： 编辑顶点

【3dmax笔记】032： 编辑顶点

一、编辑顶点概述 （1）启动安装好的3dmax软件。 （2）选择顶视图，用图形画出一个矩形。 （3）选择矩形，右击鼠标，将矩形转换成可编辑样条线。 （4）进入顶点层级。 展开可编辑样条线，选择顶点层级（快捷键为1，在不展开样条线的情况下也可以选择顶点层级）。选择后，可以…
阅读更多...
postman介绍、安装、使用、功能特点、注意事项

postman介绍、安装、使用、功能特点、注意事项

Postman是一款流行的API开发工具&#xff0c;它提供了丰富的功能&#xff0c;包括创建、测试、调试和文档化API。本文将介绍Postman的安装、使用方法&#xff0c;以及其功能特点和注意事项。 1. 介绍 Postman是一款用于构建、测试和调试API的工具&#xff0c;它提供了用户友好的…
阅读更多...
串口通信---了解

串口通信---了解

1 串口接线方式 RXD&#xff1a;数据输入引脚&#xff0c;数据接受&#xff1b;STC89系列对应P3.0口 TXD&#xff1a;数据发送引脚&#xff0c;数据发送&#xff1b;STC89系列对应P3.1口 接线方式 串口编程要素 输入/输出数据缓冲器叫做SBUF&#xff0c;都用99H地址码&#x…
阅读更多...
链式二叉树的基本操作1

链式二叉树的基本操作1

1.概念回顾 讲二叉树的基本操作之前&#xff0c;我们回顾一下二叉树的概念 在讲树之前&#xff0c;我们的每讲一种数据结构&#xff0c;无外乎就是在讲它们的增删查改&#xff0c;但是在树这里&#xff0c;就有了不小变化。 2.结点的定义 既然是链式二叉树&#xff0c;那必须…
阅读更多...
必学-设计模式

必学-设计模式

设计模式的分类 创建型模式&#xff08;Creational&#xff09;&#xff1a;关注对象的实例化过程&#xff0c;包括了如何实例化对象、隐藏对象的创建细节等。常见的创建型模式有单例模式、工厂模式、抽象工厂模式等。 结构型模式&#xff08;Structural&#xff09;&#xff…
阅读更多...
Tensorflow2.0笔记 - 循环神经网络RNN做IMDB评价分析

Tensorflow2.0笔记 - 循环神经网络RNN做IMDB评价分析

本笔记记录使用SimpleRNNCell做一个IMDB评价系统情感二分类问题的例子。 import os import time import numpy as np import tensorflow as tf from tensorflow import keras from tensorflow.keras import datasets, layers, optimizers, Sequential, metrics, Inputos.envir…
阅读更多...
VisualGLM-6B微调（V100）

VisualGLM-6B微调（V100）

Visualglm-6b-CSDN博客文章浏览阅读1.3k次。【官方教程】XrayGLM微调实践&#xff0c;&#xff08;加强后的GPT-3.5&#xff09;能力媲美4.0&#xff0c;无次数限制。_visualglm-6bhttps://blog.csdn.net/u012193416/article/details/131074962?ops_request_misc%257B%2522req…
阅读更多...
2. Linux 基本指令(上)|ls|pwd|cd|tree|touch|mkdir|rmdir|rm

2. Linux 基本指令(上)|ls|pwd|cd|tree|touch|mkdir|rmdir|rm

前言 计算机软硬件体系结构 层状结构应用软件Word&#xff0c;Matlab操作系统Windows&#xff0c;Linux设备驱动声卡驱动硬件CPU&#xff0c;内存&#xff0c;磁盘&#xff0c;显示器&#xff0c;键盘 操作系统概念 操作系统 是一款进行软硬件资源管理的软件 例子 比如在学…
阅读更多...
Join优化规则及应用层BI系统实践

Join优化规则及应用层BI系统实践

目录 一、背景 二、查询优化器概述​编辑 2.1 System R Optimizer 2.2 Volcano Optimizer 2.3 Cascade Optimizer 三、Join相关优化规则 3.1 JoinReorder 3.1.1 少量表的Reorder 3.1.2 大量表的Reorder 3.1.3 星型模型的Reorder 3.2 外连接消除 3.3 Join消除 3.4 谓…
阅读更多...
使用ROW_NUMBER()分组遇到的坑

使用ROW_NUMBER()分组遇到的坑

1、再一次清洗数据时&#xff0c;需要过滤重复数据&#xff0c;使用了ROW_NUMBER() 来分组给每组数据排序号 在获取每组的第一行数据 with records as(select cc.F_Id as Id,REPLACE(cc.F_CNKITitle,char(10),1) as F_CNKITitle,REPLACE(REPLACE(cc.F_Special,专题&#xff1…
阅读更多...
适合大学生的鸿蒙开发板-Purple Pi OH之安装Docker

适合大学生的鸿蒙开发板-Purple Pi OH之安装Docker

一、介绍 本文基于purple-pi-oh系列主板演示Linux 系统安装Docker&#xff0c;方法适用于RK3566全系列产品。本教程将指导你在基于RK3566的LInux系统上安装Docker。Docker是一个开放源代码的应用容器引擎&#xff0c;允许开发者打包他们的应用及依赖包到一个可移植的容器中&am…
阅读更多...
【银角大王——Django课程——分页显示功能实现】

【银角大王——Django课程——分页显示功能实现】

分页显示功能实现 添加假数据&#xff0c;然后演示分页功能分页——功能实现基于之前的靓号列表函数添加代码只显示10条——按照等级排序页码list表样式——bootstrap样式显示当前页面——前五页&#xff0c;后五页给当前页添加样式页码bug更改——出现负数&#xff0c;没有数据…
阅读更多...
【neteq】tgcall的调用、neteq的创建及接收侧ReceiveStatisticsImpl统计

【neteq】tgcall的调用、neteq的创建及接收侧ReceiveStatisticsImpl统计

G:\CDN\P2P-DEV\Libraries\tg_owt\src\call\call.cc基本是按照原生webrtc的来的：G:\CDN\P2P-DEV\tdesktop-offical\Telegram\ThirdParty\tgcalls\tgcalls\group\GroupInstanceCustomImpl.cpptg对neteq的使用 worker 线程创建call Call的config需要neteqfactory Call::CreateAu…
阅读更多...
MySQL——变量的浮点数问题处理

MySQL——变量的浮点数问题处理

新建链接&#xff0c;自带world数据库&#xff0c;里面自带city表格。 DQL #MySQL变量的浮点数问题处理 set dx3.14,dy3.25; select dxdy;#计算显示异常&#xff0c;会有很多00000的提示set resultdxdy; select result; 查询结果
阅读更多...
为何预测预测蛋白质结构这么重要AlphaFold 3；阿里巴巴的开源语音转文字；抱抱脸开源LeRobot

为何预测预测蛋白质结构这么重要AlphaFold 3；阿里巴巴的开源语音转文字；抱抱脸开源LeRobot

✨ 1: AlphaFold 3 谷歌DeepMind和同构实验室推出AlphaFold 3 AI模型&#xff0c;旨在精确预测生命分子的结构和相互作用。 AlphaFold 3 是由谷歌DeepMind和Isomorphic Labs开发的一款新型AI模型&#xff0c;它可以以前所未有的精确度预测蛋白质、DNA、RNA、配体&#xff08;…
阅读更多...
【VTKExamples::Rendering】第一期 TestAmbientSpheres（环境照明系数）

【VTKExamples::Rendering】第一期 TestAmbientSpheres（环境照明系数）

很高兴在雪易的CSDN遇见你 VTK技术爱好者 QQ：870202403 公众号：VTK忠粉 前言 本文分享VTK样例TestAmbientShperes，介绍环境照明系数对Actor颜色的影响，希望对各位小伙伴有所帮助！ 感谢各位小伙伴的点赞+关注，小易会继续努力分享，一起进步！ 你的点赞就是我的动…
阅读更多...
C++：重载、重写与重定义

C++：重载、重写与重定义

一、重载、重写与重定义的概念 C中&#xff0c;重载、重写和重定义是三个与函数和类成员相关的概念&#xff0c;但它们具有不同的含义和用途。 重载&#xff1a;是指在同一作用域内&#xff0c;可以有多个名称相同但参数列表&#xff08;参数类型、参数个数或参数顺序&#x…
阅读更多...
最新文章

Copyright @ 2022~2023

友情链接： 我的编程经验分享 一条长河网 尧图网站开发 尧图建网站