Python进程/线程/协程相关

发布时间：2019-09-20 07:33:23编辑：auto阅读（1654）

1、获取进程ID。（getpid）

os.getpid()

2、获取父进程ID。（getppid）

os.getppid()

3、获取线程ID。（get_ident）

（1）、进程内局部标识。


import threading
threading.get_ident()
threading.current_thread().ident

（2）、系统全局标识：python下使用ctypes获取threading线程id。




【使用线程池完成阻塞型任务】

#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))

【使用单线程完成异步型任务】

#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))




相关阅读：

1、Python自定义进程池（生产者/消费者模型）

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 ***

关键字：