Python脚本之Multiprocessing 多线程
AAB377E247752DA87288BAF935E442AC######################################
#!/usr/bin/env python
#encoding=utf-8
from multiprocessing import Process,Lock
import time,os
def say(i):
print 'nihao:',i
#lock=Lock()
for n in range(101):
p=Process(target=say,args=(n,))
p.start()
#p.join()
########################################多线程池Pool，可限制多线程数量
#!/usr/bin/env python
#encoding=utf-8
import multiprocessing
import os,sys,time
result=[]
def run_cmd(i):
print 'threading test:',i,os.getpid()
time.sleep(1.5)
p=multiprocessing.Pool(processes=25)
for n in range(100):
result.append(p.apply_async(run_cmd,('%s'%n,)))
p.close()
#p.join()
for res in result:
res.get(timeout=5)
######################################多线程pool,paramiko
import multiprocessing
import os,time
import paramiko
hosts=['192.168.1.11','192.168.1.10']
#,'192.168.1.11','192.168.1.12','192.168.1.13']
username='root'
password='123456'
port=22
name={}
d_usage={}
def cmd(hostname):
if os.system('ping %s -c 1 &>/dev/null'%hostname)==0:
paramiko.util.log_to_file('paramiko.log')
s = paramiko.SSHClient()
s.set_missing_host_key_policy(paramiko.AutoAddPolicy())
s.connect(hostname,port,username,password)
stdin,stdout,stderr=s.exec_command('df -kP')
time.sleep(2)
d_usage['%s'%hostname]= stdout.read()
print '---------------------------------------------'
print d_usage['%s'%hostname]
print stdout.read()
s.close()
else:
d_usage['%s'%hostname]='host Destination Host Unreachable'
print'host Destination Host Unreachable'
name={'xk':,'zq':,}
p=multiprocessing.Pool(processes=10)
for hostname in hosts:
p.apply_async(cmd,('%s'%hostname,))
# time.sleep(10)
time.sleep(10)
p.close()
#p.join()
#print d_usage
页:
[1]