Python脚本之Multiprocessing 多线程

yui

　　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':[25,'male'],'zq':[23,'male'],}
　　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