个人中心
文章发布
退出
作者热门文章
- ubuntu12.04环境下使用kvm ioctl接口实现最简单的虚拟机
- Ubuntu 通过无线网络安装Ubuntu Server启动系统后连接无线网络的方法
- 在Ubuntu上搭建网桥的方法
- ubuntu 虚拟机上网方式及相关配置详解
33
4
CFSDN坚持开源创造价值，我们致力于搭建一个资源共享平台，让每一个IT人在这里找到属于你的精彩世界.
这篇CFSDN的博客文章Python多线程编程之threading模块详解由作者收集整理，如果你对这篇文章有兴趣，记得点赞哟.
线程是什么？线程有啥用？线程和进程的区别是什么?
线程是操作系统能够进行运算调度的最小单位。被包含在进程中，是进程中的实际运作单位。一条线程指的是进程中一个单一顺序的控制流，一个进程中可以并发多个线程，每条线程并行执行不同的任务.
创建Thread对象 。
步骤:
1.目标函数 。
2.实例化Thread对象 。
3.调用start()方法 。
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
|
import
threading
# 目标函数1
def
fun1(num):
for
i
in
range
(num):
print
(
'线程1: 第%d次循环:'
%
i)
# 目标函数2
def
fun2(lst):
for
ele
in
lst:
print
(
'线程2: lst列表中元素 %d'
%
ele)
def
main():
num
=
10
# 实例化Thread对象
# target参数一定为一个函数，且不带括号
# args参数为元组类型，参数为一个时一定要加逗号
t1
=
threading.Thread(target
=
fun1, args
=
(num,))
t2
=
threading.Thread(target
=
fun2, args
=
([
1
,
2
,
3
,
4
,
5
],))
# 调用start方法
t1.start()
t2.start()
if
__name__
=
=
'__main__'
:
main()
|
创建子类继承threading.Thread类 。
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
|
import
threading
import
os
class
Person(threading.Thread):
def
run(
self
):
self
.sing(
5
)
self
.cook()
@staticmethod
def
sing(num):
for
i
in
range
(num):
print
(
'线程[%d]: The person sing %d song.'
%
(os.getpid(), i))
@staticmethod
def
cook():
print
(
'线程[%d]:The person has cooked breakfast.'
%
os.getpid())
def
main():
p1
=
Person()
p1.start()
p2
=
Person()
p2.start()
if
__name__
=
=
'__main__'
:
main()
|
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
|
import
threading
import
time
import
logging
def
fun1():
print
(threading.current_thread().getName(),
'starting'
)
time.sleep(
0.2
)
print
(threading.current_thread().getName(),
'exiting'
)
def
fun2():
# print(threading.current_thread().getName(), 'starting')
# time.sleep(0.3)
# print(threading.current_thread().getName(), 'exiting')
logging.debug(
'starting'
)
time.sleep(
0.3
)
logging.debug(
'exiting'
)
logging.basicConfig(
level
=
logging.DEBUG,
format
=
'[%(levelname)s] (%(threadName)-10s) %(message)s'
)
def
main():
t1
=
threading.Thread(name
=
'线程1'
, target
=
fun1)
t2
=
threading.Thread(name
=
'线程2'
, target
=
fun2)
t1.start()
t2.start()
if
__name__
=
=
'__main__'
:
main()
|
区别 。
守护线程如何搞 。
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
|
import
threading
import
time
import
logging
def
daemon():
logging.debug(
'starting'
)
# 添加延时，此时主线程已经退出，exiting不会打印
time.sleep(
0.2
)
logging.debug(
'exiting'
)
def
non_daemon():
logging.debug(
'starting'
)
logging.debug(
'exiting'
)
logging.basicConfig(
level
=
logging.DEBUG,
format
=
'[%(levelname)s] (%(threadName)-10s) %(message)s'
)
def
main():
# t1 = threading.Thread(name='线程1', target=daemon)
# t1.setDaemon(True)
t1
=
threading.Thread(name
=
'线程1'
, target
=
daemon, daemon
=
True
)
t2
=
threading.Thread(name
=
'线程2'
, target
=
non_daemon)
t1.start()
t2.start()
# 等待守护线程完成工作需要调用join()方法，默认情况join会无限阻塞，可以传入浮点值，表示超时时间
t1.join(
0.2
)
t2.join(
0.1
)
if
__name__
=
=
'__main__'
:
main()
|
目的:
Python线程中资源共享，如果不对资源加上互斥锁，有可能导致数据不准确.
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
|
import
threading
import
time
g_num
=
0
def
fun1(num):
global
g_num
for
i
in
range
(num):
g_num
+
=
1
print
(
'线程1 g_num = %d'
%
g_num)
def
fun2(num):
global
g_num
for
i
in
range
(num):
g_num
+
=
1
print
(
'线程2 g_num = %d'
%
g_num)
def
main():
t1
=
threading.Thread(target
=
fun1, args
=
(
1000000
,))
t2
=
threading.Thread(target
=
fun1, args
=
(
1000000
,))
t1.start()
t2.start()
if
__name__
=
=
'__main__'
:
main()
time.sleep(
1
)
print
(
'主线程 g_num = %d'
%
g_num)
|
互斥锁 。
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
|
import
threading
import
time
g_num
=
0
L
=
threading.Lock()
def
fun1(num):
global
g_num
L.acquire()
for
i
in
range
(num):
g_num
+
=
1
L.release()
print
(
'线程1 g_num = %d'
%
g_num)
def
fun2(num):
global
g_num
L.acquire()
for
i
in
range
(num):
g_num
+
=
1
L.release()
print
(
'线程2 g_num = %d'
%
g_num)
def
main():
t1
=
threading.Thread(target
=
fun1, args
=
(
1000000
,))
t2
=
threading.Thread(target
=
fun1, args
=
(
1000000
,))
t1.start()
t2.start()
if
__name__
=
=
'__main__'
:
main()
time.sleep(
1
)
print
(
'主线程 g_num = %d'
%
g_num)
|
互斥锁引发的另一个问题：死锁 。
死锁产生的原理:
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
|
import
threading
import
time
g_num
=
0
L1
=
threading.Lock()
L2
=
threading.Lock()
def
fun1():
L1.acquire(timeout
=
5
)
time.sleep(
1
)
L2.acquire()
print
(
'产生死锁，并不会打印信息'
)
L2.release()
L1.release()
def
fun2():
L2.acquire(timeout
=
5
)
time.sleep(
1
)
L1.acquire()
print
(
'产生死锁，并不会打印信息'
)
L1.release()
L2.release()
def
main():
t1
=
threading.Thread(target
=
fun1)
t2
=
threading.Thread(target
=
fun2)
t1.start()
t2.start()
if
__name__
=
=
'__main__'
:
main()
time.sleep(
1
)
print
(
'主线程 g_num = %d'
%
g_num)
|
如何避免产生死锁:
锁超时操作 。
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
|
import
threading
import
time
g_num
=
0
L1
=
threading.Lock()
L2
=
threading.Lock()
def
fun1():
L1.acquire()
time.sleep(
1
)
L2.acquire(timeout
=
5
)
print
(
'超时异常打印信息1'
)
L2.release()
L1.release()
def
fun2():
L2.acquire()
time.sleep(
1
)
L1.acquire(timeout
=
5
)
print
(
'超时异常打印信息2'
)
L1.release()
L2.release()
def
main():
t1
=
threading.Thread(target
=
fun1)
t2
=
threading.Thread(target
=
fun2)
t1.start()
t2.start()
if
__name__
=
=
'__main__'
:
main()
time.sleep(
1
)
print
(
'主线程 g_num = %d'
%
g_num)
|
到此这篇关于Python多线程编程之threading模块详解的文章就介绍到这了,更多相关python threading模块内容请搜索我以前的文章或继续浏览下面的相关文章希望大家以后多多支持我！ 。
原文链接：https://blog.csdn.net/qq_31385393/article/details/115873831 。
最后此篇关于Python多线程编程之threading模块详解的文章就讲到这里了,如果你想了解更多关于Python多线程编程之threading模块详解的内容请搜索CFSDN的文章或继续浏览相关文章，希望大家以后支持我的博客！ 。
33
4
0
我最近在我的机器上安装了 cx_Oracle 模块，以便连接到远程 Oracle 数据库服务器。 (我身边没有 Oracle 客户端)。 Python:版本 2.7 x86 Oracle:版本 11.
我想从 python timeit 模块检查打印以下内容需要多少时间，如何打印， import timeit x = [x for x in range(10000)] timeit.timeit("
我盯着 vs 代码编辑器上的 java 脚本编码，当我尝试将外部模块包含到我的项目中时，代码编辑器提出了这样的建议 -->(文件是 CommonJS 模块；它可能会转换为 ES6 模块。 )..有什么
我有一个 Node 应用程序，我想在标准 ES6 模块格式中使用(即 "type": "module" in the package.json ，并始终使用 import 和 export)而不转译为
我正在学习将 BlueprintJS 合并到我的 React 网络应用程序中，并且在加载某些 CSS 模块时遇到了很多麻烦。 我已经安装了 npm install @blueprintjs/core和
我需要重构一堆具有这样的调用的文件 define(['module1','module2','module3' etc...], function(a, b, c etc...) { //bun
我是 Angular 的新手，正在学习各种教程(Codecademy、thinkster.io 等)，并且已经看到了声明应用程序容器的两种方法。首先: var app = angular.module
我正在尝试将 OUnit 与 OCaml 一起使用。 单元代码源码(unit.ml)如下: open OUnit let empty_list = [] let list_a = [1;2;3] le
我在 Angular 1.x 应用程序中使用 webpack 和 ES6 模块。在我设置的 webpack.config 中: resolve: { alias: { 'angular':
internal/modules/cjs/loader.js:750 return process.dlopen(module, path.toNamespacedPath(filename));
在本教程中，您将借助示例了解 JavaScript 中的模块。 随着我们的程序变得越来越大，它可能包含许多行代码。您可以使用模块根据功能将代码分隔在单独的文件中，而不是将所有内容都放在一个文件
我想知道是否可以将此代码更改为仅调用 MyModule.RED 而不是 MyModule.COLORS.RED。我尝试将 mod 设置为变量来存储颜色，但似乎不起作用。难道是我方法不对？ (funct
我有以下代码。它是一个 JavaScript 模块。 (function() { // Object var Cahootsy; Cahootsy = { hello:
关闭。这个问题是 opinion-based 。它目前不接受答案。 想要改进这个问题？更新问题，以便 editing this post 可以用事实和引文来回答它。 关闭 2 年前。 Improve
从用户的角度来看，一个模块能够通过 require 加载并返回一个 table，模块导出的接口都被定义在此 table 中（此 table 被作为一个 namespace）。所有的标准库都是模块。标
Ruby的模块非常类似类,除了: 模块不可以有实体 模块不可以有子类 模块由module...end定义. 实际上...模块的'模块类'是'类的类'这个类的父类.搞懂了吗?不懂?让我们继续看
我有一个脚本，它从 CLI 获取 3 个输入变量并将其分别插入到 3 个变量: GetOptions("old_path=s" => \$old_path, "var=s" =
我有一个简单的 python 包，其目录结构如下: wibble | |-----foo | |----ping.py | |-----bar | |----pong.py 简单的
这种语法会非常有用——这不起作用有什么原因吗？谢谢! module Foo = { let bar: string = "bar" }; let bar = Foo.bar; /* works *
我想运行一个命令: - name: install pip shell: "python {"changed": true, "cmd": "python <(curl https://boot
我是一名优秀的程序员,十分优秀！