- Java锁的逻辑(结合对象头和ObjectMonitor)
- 还在用饼状图?来瞧瞧这些炫酷的百分比可视化新图形(附代码实现)⛵
- 自动注册实体类到EntityFrameworkCore上下文,并适配ABP及ABPVNext
- 基于Sklearn机器学习代码实战
欢迎来到我们的系列博客《Python全景系列》!在这个系列中,我们将带领你从Python的基础知识开始,一步步深入到高级话题,帮助你掌握这门强大而灵活的编程语法。无论你是编程新手,还是有一定基础的开发者,这个系列都将提供你需要的知识和技能.
。
这是本系列的第五篇,我们将深入探讨Python中的并发编程,特别关注多线程和多进程的应用。我们将先从基本概念开始,然后通过详细举例探讨每一种机制,最后分享一些实战经验以及一种优雅的编程技巧.
。
线程是操作系统中最小的执行单元。在单个程序或进程内,可以并发运行多个线程,共享进程的资源,如内存和文件描述符.
Python支持多线程编程,并提供了`threading`模块作为支持。这个模块提供了`Thread`类,我们可以通过创建其实例并向其传递函数来创建新线程。当然,你也可以通过继承`Thread`类并重写`run()`方法来创建自定义线程。下面是一个多线程编程的例子:
import
threading
def
print_numbers():
for
i
in
range(10
):
print
(i)
def
print_letters():
for
letter
in
'
abcdefghij
'
:
print
(letter)
#
创建线程
t1 = threading.Thread(target=
print_numbers) t2
= threading.Thread(target=
print_letters)
#
启动线程
t1.start() t2.start()
#
等待线程结束
t1.join() t2.join()
。
在上面的例子中,我们定义了两个函数:一个打印数字,另一个打印字母。然后我们创建了两个线程,每个线程的目标是执行这些函数。`start()`方法用于启动线程,而`join()`方法用于等待线程完成.
。
尽管Python的多线程因为全局解释器锁(GIL)的存在,并不能实现真正的并行,但是它们在I/O密集型任务中仍然很有用。GIL是CPython解释器的一个互斥锁,保证在任何时刻只有一个线程在执行。这意味着在CPU密集型任务中,多线程可能不是最佳选择,因为它们无法充分利用多核CPU.
然而,在I/O密集型任务中,多线程能够提高程序性能。例如,如果一个程序需要从多个源下载文件,那么使用多线程可以使得当一个线程等待网络响应时,其他线程可以继续下载其他文件。这样,程序可以在同一时间从多个源下载文件,大大提高了效率.
。
进程是操作系统中独立的执行实体,每个进程都有自己的内存空间、文件描述符等资源。与线程不同,进程之间的资源 。
并不共享,每个进程都有自己独立的资源.
。
Python通过`multiprocessing`模块提供了多进程支持。类似于多线程,我们可以通过创建`Process`类的实例并向其传递函数来创建新进程。我们也可以通过继承`Process`类并重写`run()`方法来创建自定义进程.
以下是一个简单的多进程编程的例子:
import
multiprocessing
def
print_numbers():
for
i
in
range(10
):
print
(i)
def
print_letters():
for
letter
in
'
abcdefghij
'
:
print
(letter)
#
创建进程
p1 = multiprocessing.Process(target=
print_numbers) p2
= multiprocessing.Process(target=
print_letters)
#
启动进程
p1.start() p2.start()
#
等待进程结束
p1.join() p2.join()
这个例子和前面的多线程例子类似,不同的是这里我们创建的是两个进程,而不是线程.
。
多进程可以实现真正的并行,使得Python程序可以利用多核CPU。因此,对于CPU密集型任务,多进程通常比多线程更有优势。另一方面,多进程的开销比多线程大,而且进程间的通信和同步也比线程间的更为复杂。因此,对于I/O密集型任务,或者需要频繁通信的任务,多线程可能会是更好的选择.
在Python中,`concurrent.futures`模块为多线程和多进程编程提供了高级接口,可以让我们更加简洁地编写代码.
这个模块提供了`ThreadPoolExecutor`和`ProcessPoolExecutor`两个类,它们分别用于创建线程池和进程池。这两个类都实现了相同的接口,你可以使用`submit()`方法提交任务,然后使用`as_completed()`函数等待任务完成.
下面是一个使用`concurrent.futures`模块的示例:
import
concurrent.futures
def
print_numbers():
for
i
in
range(10
):
print
(i)
def
print_letters():
for
letter
in
'
abcdefghij
'
:
print
(letter)
#
使用线程池
with concurrent.futures.ThreadPoolExecutor() as executor: future1
=
executor.submit(print_numbers) future2
=
executor.submit(print_letters)
for
future
in
concurrent.futures.as_completed([future1, future2]):
pass
#
使用进程池
with concurrent.futures.ProcessPoolExecutor() as executor: future1
=
executor.submit(print_numbers) future2
=
executor.submit(print_letters)
for
future
in
concurrent.futures.as_completed([future1, future2]):
pass
在上面的例子中,我们创建了线程池和进程池,然后向它们提交任务。可以看到,使用`concurrent.futures`模块,我们的代码更加简洁,易读 性和可维护性也有所提高.
Python的多线程和多进程都是非常强大的工具,可以帮助我们编写出更高效的程序。然而,它们也各有优缺点,需要我们根据具体的任务和需求来选择。同时,Python还提供了`concurrent.futures`模块,可以使我们的并发编程变得更加简单和高效.
我们希望本文能帮助你更好地理解和使用Python的多线程和多进程。如果你有任何疑问或者建议,欢迎在评论区留言.
【第一时间获得Python全视角更新信息,请关注本人微信公众号: Python 全视角 】 。
。
最后此篇关于解锁Python并发编程:多线程和多进程的神秘面纱揭晓的文章就讲到这里了,如果你想了解更多关于解锁Python并发编程:多线程和多进程的神秘面纱揭晓的内容请搜索CFSDN的文章或继续浏览相关文章,希望大家以后支持我的博客! 。
我注意到,当我打开我的应用程序并等待足够长的时间让我的手机自行锁定时,当我解锁它时,当前内容 View 未处于全屏模式。它不显示顶部栏,而是全黑线...如果我去另一个 Activity 并返回它再次修
我必须处理设计限制(依赖性问题)以不对互斥体使用范围保护。 示例代码: template class Test { MutexType myMutex; public: void f(
我正在尝试像这样使 my_class 线程安全。 class my_class { const std::vector& get_data() const { //lock so that
我想让手机在手机被锁定(锁定 = 键盘被锁定)并且用户想要解锁时询问一个问题(来自数据库)。如果答案正确,则手机解锁,否则手机会询问另一个问题。 我不知道如何检测解锁并在需要时解锁/锁定手机。 请帮帮
我有一个对 accept() 的阻塞调用。我从另一个线程关闭套接字,希望它能解除对 accept() 调用的阻塞,它确实如此,但我有一个情况,它没有:例如线程A进入accept(),线程B关闭sock
我在 C# 中有一个可以从多个线程调用多次的函数,我希望它只执行一次,所以我想到了这个: class MyClass { bool done = false; public void
锁定数据库的一个表 复制代码 代码如下: SELECT * FROM table WITH (HOLDLOCK) 注意: 锁定数据库的一个表的区别
我已经使用腻子在我的 ec2 实例上安装了 jenkins,从我的 Windows 系统 当我尝试通过网络访问 jenkins 时,我使用/var/lib/jenkins/secrets/initia
每次我打开我的电脑并尝试连接到 HR 数据库时,都会弹出一个错误提示被阻止,然后我转到 SQLPLUS 并以 SYSDBA 身份登录,并执行以下脚本: 我的问题是,我是否总是必须这样做?有什么办法让它
所以我的手机在引导加载程序中,我想解锁它 所以我输入 fastboot oem unlock 我明白了 D:\Minimal ADB and Fastboot>fastboot oem unlock
在我的应用程序中,我希望即使在应用程序终止后我的应用程序仍处于事件状态。我希望当“滑动解锁”我的应用程序启动时。 有可能吗?我怎样才能在不越狱的情况下做到这一点...... 这是为用户提供便利的功能。
即使我的 iPhone 使用电缆连接并解锁,它也会显示警告“Xcode 9.3 无法在 iPhone 上启动应用程序,因为设备已锁定”。我不知道该怎么办?有人对此有适当的解决方案吗?请 最佳答案 只需
我看到一个非常奇怪的行为,我试图了解它是否是这样设计的,或者只是没有从我的应用程序中正确处理。 我的应用程序以 UIAlertViews 的形式发送推送通知。当设备未锁定时,UIAlertViews
该文档说,从一个线程进行锁定并从另一个rwlock进行解锁会导致未定义的行为。我有一个数组和两个线程,一个分配它,一个释放它,这是一个周期发生的,也有一些线程在其中进行读/写操作,但是它们从不重叠,因
解锁 Oracle 表有哪些不同的技术? 我尝试过的。 获取锁定表的对象ID: SELECT object_id FROM dba_objects WHERE object_name='YOUR TA
我运行@apxchpwd.sql并用这个脚本给帐户倒霉 alter session set current_schema = APEX_050100; declare l_workspace_id
我想在 Chrome 扩展程序中提供一些高级功能。这个想法是,只要用户通过 PayPal 捐赠了一定金额,就可以使用后者的附加功能。 目前我的策略是这样的: 1/。用户填写 PayPal 表格。 2/
我构建了一个包含 IAP(应用内购买)的应用。该应用程序是使用 UINavigationController 构建的。当用户决定购买内容时,解锁功能会解锁该内容。然后,用户点击后退按钮,他们将返回主菜
我有一个只能通过静态方法从外部访问的类。然后,这些静态方法创建该类的一个对象以在该方法中使用,然后它们返回并且该对象可能被销毁。该类是几个配置文件的 getter/setter,现在我需要在对配置文件
我可以在超出 scoped_lock 范围之前解锁互斥锁吗?我怎么能那样做? {boost::mutex::scoped_lock lock(mutex); if(conditionaA) {
我是一名优秀的程序员,十分优秀!