首页 » python » 正文

python 多进程例子

2015/11/10 | python | Zhiming Zhang | 暂无评论 | 1180 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)

istio Ingress Gateways - 十一月 25, 2020
Istio VirtualService - 十一月 23, 2020
istio 组件 - 十一月 18, 2020

发表评论取消