1、获取进程ID。（getpid）
|
1
|
os.getpid()
|
2、获取父进程ID。（getppid）
|
1
|
os.getppid()
|
3、获取线程ID。（get_ident）
（1）、进程内局部标识。
|
1
2
3
|
import
threading
threading.get_ident()
threading.current_thread().ident
|
（2）、系统全局标识：python下使用ctypes获取threading线程id。
【使用线程池完成阻塞型任务】
|
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
39
40
|
#encoding=utf-8
#author: walker
#date: 2017-03-27
#summary: 使用线程池完成阻塞型任务
#Python 3.6.1 (v3.6.1:69c0db5, Mar 21 2017, 18:41:36) [MSC v.1900 64 bit (AMD64)] on win32
import
time
import
random
import
threading
import
concurrent.futures
#同步型任务
def
TaskSync(taskid, sleepTime):
print
(
'thread_%05d %s sleep %d ...'
%
(threading.get_ident(), taskid, sleepTime))
time.sleep(sleepTime)
#睡觉任务
print
(
'\t\tthread_%05d %s sleep %d over'
%
(threading.get_ident(), taskid, sleepTime))
return
taskid, sleepTime
#处理所有任务
def
ProcAll(taskList):
pool
=
concurrent.futures.ThreadPoolExecutor(
4
)
futureList
=
list
()
for
taskid, sleepTime
in
taskList:
#提交所有任务
futureList.append(pool.submit(TaskSync, taskid, sleepTime))
totalSleepTime
=
0
for
future
in
concurrent.futures.as_completed(futureList):
task, sleepTime
=
future.result()
print
(
'\t\t\t\t\t\t%s sleep %d over'
%
(task, sleepTime))
totalSleepTime
+
=
sleepTime
return
totalSleepTime
if
__name__
=
=
'__main__'
:
startTime
=
time.time()
taskList
=
[(
'task_%d'
%
id
, random.randint(
1
,
5
))
for
id
in
range
(
0
,
9
)]
print
(
'taskList:%s'
%
repr
(taskList))
totalSleepTime
=
ProcAll(taskList)
print
(
'totalSleepTime: %d s'
%
totalSleepTime)
print
(
'real cost time:%.2f'
%
(time.time()
-
startTime))
|
【使用单线程完成异步型任务】
|
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
|
#encoding=utf-8
#author: walker
#date: 2017-03-27
#summary: 使用单线程完成异步型任务
#Python 3.6.1 (v3.6.1:69c0db5, Mar 21 2017, 18:41:36) [MSC v.1900 64 bit (AMD64)] on win32
import
asyncio
import
time
import
random
#协程型任务
async
def
TaskAsync(taskid, sleepTime):
print
(
'%s sleep %d ...'
%
(taskid, sleepTime))
await asyncio.sleep(sleepTime)
#睡觉任务
print
(
'\t%s sleep %d over'
%
(taskid, sleepTime))
return
taskid, sleepTime
#处理所有任务
async
def
ProcAll(taskList):
coroutineList
=
list
()
for
taskid, sleepTime
in
taskList:
coroutineList.append(asyncio.ensure_future((TaskAsync(taskid, sleepTime))))
totalSleepTime
=
0
for
f
in
asyncio.as_completed(coroutineList):
task, sleepTime
=
await f
print
(
'\t\t\t%s sleep %d over'
%
(task, sleepTime))
totalSleepTime
+
=
sleepTime
return
totalSleepTime
if
__name__
=
=
'__main__'
:
startTime
=
time.time()
taskList
=
[(
'task_%d'
%
id
, random.randint(
1
,
5
))
for
id
in
range
(
0
,
9
)]
print
(
'taskList:%s'
%
repr
(taskList))
loop
=
asyncio.get_event_loop()
totalSleepTime
=
loop.run_until_complete(ProcAll(taskList))
print
(
'totalSleepTime: %d s'
%
totalSleepTime)
print
(
'real cost time:%.2f'
%
(time.time()
-
startTime))
|
相关阅读：
2、asyncio — Asynchronous I/O, event loop, coroutines and tasks
3、concurrent.futures — Launching parallel tasks
4、multiprocessing — Process-based parallelism
5、协程与async/await语法（PEP 0492 Coroutines with async and await syntax 中文翻译）
6、Python协程：从yield/send到async/await
*** walker ***
本文转自walker snapshot博客51CTO博客，原文链接http://blog.51cto.com/walkerqt/1893879如需转载请自行联系原作者
RQSLT
