首页 » python » 正文

python 多进程例子

2015/11/10 | python | Zhiming Zhang | 暂无评论 | 1067 views




		
		
			
			
Python
			
			#!/usr/bin/env python
# coding=utf-8

from multiprocessing import Pool
import os,time,random
import subprocess

def long_time_task(name):
    webiste = ['www.baidu.com','www.youku.com','www.tudou.com','www.iqiyi.com','www.google.com','www.503error.com']
    print '---------Run task %s (%s)...' % (name,os.getpid())
    start = time.time()
    time.sleep(2)
    print name
    print webiste[name]
    subprocess.call(['ping','-c','1',webiste[name-1]])
    #print 'Result:',r
    end = time.time()
    print '*********Task %s run %0.2f second' % (name,end-start)


if __name__ =='__main__':
    print 'Parent process %s',os.getpid()
    p = Pool(4)
    for i in range(5):
        p.apply_async(long_time_task, args=(i,)) 
    print 'Waiting all the process'
    p.close()
    p.join()
    print 'All done'
			
				
					
				
					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
				
						#!/usr/bin/env python
# coding=utf-8
 
from multiprocessing import Pool
import os,time,random
import subprocess
 
def long_time_task(name):
    webiste = ['www.baidu.com','www.youku.com','www.tudou.com','www.iqiyi.com','www.google.com','www.503error.com']
    print '---------Run task %s (%s)...' % (name,os.getpid())
    start = time.time()
    time.sleep(2)
    print name
    print webiste[name]
    subprocess.call(['ping','-c','1',webiste[name-1]])
    #print 'Result:',r
    end = time.time()
    print '*********Task %s run %0.2f second' % (name,end-start)
 
 
if __name__ =='__main__':
    print 'Parent process %s',os.getpid()
    p = Pool(4)
    for i in range(5):
        p.apply_async(long_time_task, args=(i,)) 
    print 'Waiting all the process'
    p.close()
    p.join()
    print 'All done'
					
				
			
		

 
[zhizhang@zhizhang-desktop-nay test]$ vi myProcessPoll.py

[zhizhang@zhizhang-desktop-nay test]$ cat myProcessPoll.py


		
		
			
			
Python
			
			#!/usr/bin/env python
# coding=utf-8

from multiprocessing import Pool
import os,time,random
import subprocess

def long_time_task(name):
    webiste = ['www.baidu.com','www.youku.com','www.tudou.com','www.iqiyi.com','www.google.com','www.503error.com']
    print '---------Run task %s (%s)...' % (name,os.getpid())
    start = time.time()
    time.sleep(2)
    print name
    print webiste[name]
    subprocess.call(['ping','-c','1',webiste[name-1]])
    #print 'Result:',r
    end = time.time()
    print '*********Task %s run %0.2f second' % (name,end-start)


if __name__ =='__main__':
    print 'Parent process %s',os.getpid()
    p = Pool(4)
    for i in range(5):
        p.apply_async(long_time_task, args=(i,)) 
    print 'Waiting all the process'
    p.close()
    p.join()
    print 'All done'
			
				
					
				
					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
				
						#!/usr/bin/env python
# coding=utf-8
 
from multiprocessing import Pool
import os,time,random
import subprocess
 
def long_time_task(name):
    webiste = ['www.baidu.com','www.youku.com','www.tudou.com','www.iqiyi.com','www.google.com','www.503error.com']
    print '---------Run task %s (%s)...' % (name,os.getpid())
    start = time.time()
    time.sleep(2)
    print name
    print webiste[name]
    subprocess.call(['ping','-c','1',webiste[name-1]])
    #print 'Result:',r
    end = time.time()
    print '*********Task %s run %0.2f second' % (name,end-start)
 
 
if __name__ =='__main__':
    print 'Parent process %s',os.getpid()
    p = Pool(4)
    for i in range(5):
        p.apply_async(long_time_task, args=(i,)) 
    print 'Waiting all the process'
    p.close()
    p.join()
    print 'All done'

About
Latest Posts

Zhiming Zhang

Senior devops at Appannie

一个奔跑在运维路上的胖子

Latest posts by Zhiming Zhang (see all)

terraform build in function 内置函数 - 九月 14, 2020
terraformconditionals - 九月 14, 2020
Kubernete 开发系列如果不使用Operator，我们如何部署一个应用 - 七月 20, 2020

发表评论取消