aa.pydef test():    print("ok")class C:    def __init__(self):        self.name = ‘abc‘__import__data = http://www.mamicode.com/__import__(‘day5.aa‘)"utf-8"))-------------------------------------------------------------

while True:    cmd = input(">>:").strip()    if len(cmd) == 0:continue    if cmd.startwith("get"):        clinet.send(cmd.encode())        file_toal_size = int(server_response.decode())        received_size = 0        filename = cmd.split()[1]        f = open(filename,‘wb‘)        m = hashlib.md5()        while received_size < file_toal_size:            if file_toal_size - received_size > 1024:                size = 1024            else:                size = file_toal_size - received_size            data = http://www.mamicode.com/client.recv(size)"{}wrote:".format(self.client_address[0]))                print(self.data)                self.request.send(self.data.upper())            except ConnectionAbortedError as e:                print("ree",e)                breakif __name__ == "__main__":    HOST,PORT = "localhost",9999

#!/usr/bin/env python# _*_ encoding:utf-8 _*_import paramiko#创建SSH对象ssh = paramiko.SSHClient()#允许链接不在know_host文件主机中ssh.set_missing_host_key_policy(paramiko.AutoAddPolicy())#链接服务器ssh.connect(hostname=‘192.168.80.11‘,port=22,username=‘root‘,password=‘123.com‘)#执行命令stdin,stdout,stderr = ssh.exec_command(‘df‘)#获取结果res,err = stdout.read(),stderr.read()resilt = res if res else errprint(resilt)#关闭连接ssh.close()-------------------------------------------------------transport = paramiko.Transport((‘192.168.80.11‘,22))transport.connect(username=‘root‘,password=‘123.com‘)ssh = paramiko.SSHClient()ssh._transport = transportstdin,stdout,stderr = ssh.exec_command(‘df‘)print(stdout.read())transport.close()

transport = paramiko.Transport((‘192.168.80.11‘,22))transport.connect(username=‘root‘,password=‘123.com‘)sftp = paramiko.SFTPClient.from_transport(transport)#上传文件sftp.put(‘windows.txt‘,‘/root/win.txt‘)#下载文件#sftp.get(‘linux.txt‘,‘linux.txt‘)transport.close()

linux 拷贝公钥ssh-copy-id "root@192.168.80.11"#指定公钥private_key = paramiko.RSAKey.from_private_key_file(‘id_rsa‘)ssh = paramiko.SSHClient()ssh.set_missing_host_key_policy(paramiko.AutoAddPolicy())ssh.connect(hostname=‘192.168.80.11‘,port=22,username=‘root‘,pkey=private_key)stdin,stdout,stderr = ssh.exec_command(‘df‘)result = stdout.read()print(result)ssh.close()

private_key = paramiko.RSAKey.from_private_key_file(‘id_rsa‘)transport = paramiko.Transport((‘192.168.80.11‘,22))transport.connect(username=‘root‘,pkey=private_key)sftp = paramiko.SFTPClient.from_transport(transport)sftp.put(‘windows.txt‘,‘/root/windows.txt‘)sftp.get(‘linux.txt‘,‘linux.txt‘)transport.close()

def run(n):    print(‘task‘,n)    time.sleep(2)t1=threading.Thread(target=run,args=(‘t1‘,))t2=threading.Thread(target=run,args=(‘t2‘,))t1.start()t2.start()############import threadingimport timeclass MyThread(threading.Thread):    def __init__(self,n):        super(MyThread,self).__init__()        self.n = n    def run(self):        print("runnint task",self.n)t1 = MyThread("t1")t1.start()################start_time = time.time()t_objs = []def run(n):    print(‘task‘,n)    time.sleep(2)for i in range(50):    t = threading.Thread(target=run,args=(‘t-%s‘%i,))    t.start()    t_objs.append(t)for t in t_objs:    t.join()print(‘--------------all-------------‘)print("cost",time.time() - start_time)

print(‘-all--‘,threading.current_thread(),threading.active_count())

import threadingimport timestart_time = time.time()t_objs = []def run(n):    print(‘task‘,n)    time.sleep(2)for i in range(50):    t = threading.Thread(target=run,args=(‘t-%s‘%i,))    t.setDaemon(True)           #把子线程变成守护线程(守护线程，主线程执行完推出，不等待守护线程执行结束)    t.start()    t_objs.append(t)for t in t_objs:    t.join()print(‘--------------all-------------‘,threading.current_thread(),threading.active_count())print("cost",time.time() - start_time)

python只能执行一个进程，所以在执的多进程工作室，是利用上下切花来完成的因为python是调用C语言原始的进程接口，不可以调整 进程工作的顺序，在同一时间内只有一个进程在处理数据

互诉锁 防止上下切换覆盖数据 import threadingimport timedef run(n):    lock.acpuire()   #加锁    global num    num += 1    time.sleep(1)    lock.release()   #释放锁lock = threading.Lock() #调用锁num = 0t_objs = []for i in range(50):    t = threading.Thread(target=run,args=("t-%s"%i,))    t.start()    t_objs.append(t)for  t in t_objs:    t.join()print(‘num‘,num)

递归锁 防止锁顺序错乱import threading,timedef run1():    print("grab the first part dara")    lock.acquire()    global num    num +=1    lock.release()    return numdef run2():    print("grab the second part data")    lock.acquire()    global num2    num2+=2    lock.release()    return num2def run3():    lock.acquire()    res = run1()    print("----run1 run2-----")    res2 = run2()    lock.release()    print(res,res2)if __name__ == ‘__main__‘:    num,num2 = 0,0    lock = threading.RLock()    for i in range(10):        t = threading.Thread(target=run3)        t.start()while threading.active_count() !=1:    print(threading.active_count())else:    print(num,num2)

互斥锁 同时只允许一个线程更改数据，而Semaphore是同时允许一定数量的线程更改数据 ，比如厕所有3个坑，那最多只允许3个人上厕所，后面的人只能等里面有人出来了才能再进去。import threading,timedef run(n):    semaphore.acquire()    time.sleep(1)    print("run the threading:%s\n"%n)    semaphore.release()if __name__ == ‘__main__‘:    semaphore = threading.BoundedSemaphore(5)  #允许5个线程同时运行    for i in range(20):        t = threading.Thread(target=run,args=(i,))        t.start()while threading.active_count() !=1:    passelse:    print(‘----all-------‘)

import threading,timeevent = threading.Event()def lighter():    count = 0    event.set()    while True:        if count >5 and count <10:            event.clear()            print("\033[41m--->红灯\033[0m")        elif count >10:            event.set()            count = 0        else:            print("\033[42m--->绿灯\033[0m")        time.sleep(1)        count +=1def car(name):    while True:        if event.is_set():            print("[%s] running..."% name)            time.sleep(1)        else:            print("[%s]sees red light waiting.."%name)            event.wait()            print("\033[34m[%s] green ligth is on start going....\033[0m"%name)light = threading.Thread(target=lighter,)light.start()car1 = threading.Thread(target=car,args=("Tesla",))car1.start()

q = queue.Queue()# q = queue.Queue(maxsize=3)  设置队列数量q.put(1)                      传数据q.put(2)q.put(3)print(q.qsize())              查看队列大小print(q.get())                取数据print(q.get())# print(q.get_nowait())       取数据为空时不会卡住# print(q.get(block=False))   设置false取数据为空时不会卡住print(q.get(timeout=1))       设置其数据时间为1秒

import queueq = queue.LifoQueue()q.put(1)q.put(2)q.put(2)print(q.get())print(q.get())print(q.get())

import queueq = queue.PriorityQueue()q.put((-1,"a"))q.put((3,"b"))q.put((6,"c"))print(q.get())print(q.get())print(q.get())

import threadingimport queueq = queue.Queue()def producer():    for i in range(10):        q.put("骨头%s"%i)    print("开始等待骨头被取走。。。")    q.join()    print("所有骨头被取完了。。。")def consumer(n):    while q.qsize() >0:        print("%s 取到"%n,q.get())        q.task_done()p = threading.Thread(target=producer,)p.start()# b = threading.Thread(target=consumer,args=("abc",))# b.start()consumer("abc")

def run(name):    time.sleep(2)    print("hello",name)if __name__ == ‘__main__‘:    for i in range(10):        p = multiprocessing.Process(target=run,args=("bob %s"%i,))        p.start()def thread_run():    print(threading.get_ident())  #返回当前线程的“线程标识符def run(name):    time.sleep(2)    print("hello",name)    t = threading.Thread(target=thread_run,)    t.start()if __name__ == ‘__main__‘:    for i in range(10):        p = multiprocessing.Process(target=run,args=("bob %s"%i,))        p.start()

from multiprocessing import Process,Queuedef f(qq):    qq.put([42,None,‘hello‘])if __name__ == ‘__main__‘:    q = Queue()    p = Process(target=f,args=(q,))    p.start()    print(q.get())    p.join()####################from multiprocessing import Processimport osdef info(title):    print(title)    print(‘module name‘,__name__)    print(‘parent process‘,os.getppid())  打印父进程id    print(‘process id:‘,os.getpid())      打印子进程id    print("\n\n")def f(name):    info(‘\033[31mfunction f\033[0m‘)    print(‘hello‘,name)if __name__ == ‘__main__‘:    info(‘\033[32;1mmain process line\033[0m‘)    p = Process(target=f,args=(‘bob‘,))    p.start()    p.join()	#Pipes#Pipe是通过管道传送和接受数据的from multiprocessing import Process,Pipedef f(conn):    conn.send([42,None,"hello"])    conn.close()if __name__ == ‘__main__‘:    parent_conn,child_conn = Pipe()    p = Process(target=f,args=(child_conn,))    p.start()    print(parent_conn.recv())    p.join()

from multiprocessing  import Process,Managerimport osdef f(d,l):    d[os.getpid()] = os.getpid()    l.append(os.getpid())    print(l)    print(d)if __name__ == ‘__main__‘:    with Manager() as manager:        d = manager.dict()        l = manager.list(range(5))        p_list =[]        for i in range(10):            p = Process(target=f,args=(d,l,))            p.start()            p_list.append(p)        for res in p_list:            res.join()        # print(d)        # print(l)		----------------------------------------------from multiprocessing import Process,Lockdef f(l,i):    l.acquire()    try:        print(‘hello world‘,i)    finally:        l.release()if __name__ == ‘__main__‘:     lock = Lock()     for num in range(10):         Process(target=f,args=(lock,num)).start()

from multiprocessing import process,Pool,freeze_support   (windows 需要加,freeze_support)import time,osdef Foo(i):    time.sleep(2)    print(‘in process‘,os.getpid())    return i + 100def Bar(arg):    print(‘-->exec done:‘,arg,os.getpid())if __name__ == ‘__main__‘:    pool = Pool(processes=3)      允许进程池同时放入5个进程    print("主进程",os.getpid())    for i in range(10):        pool.apply_async(func=Foo,args=(i,),callback=Bar)  #同步(并行)    （callback方法 执行完Foo执行Bar 避免重复的长连接）        #pool.apply(func=Foo,args=(i,)) 串行        print(‘end‘)    pool.close()    pool.join()

import timeimport queuedef consumer(name):    print("--->starting eating baozi...")    while True:        new_baozi = yield        print("[%s] is eating baozi %s" % (name,new_baozi))        #time.sleep(1) def producer():     r = con.__next__()    r = con2.__next__()    n = 0    while n < 5:        n +=1        con.send(n)        con2.send(n)        print("\033[32;1m[producer]\033[0m is making baozi %s" %n )  if __name__ == ‘__main__‘:    con = consumer("c1")    con2 = consumer("c2")    producer()#########################from greenlet import greenletdef test1():    print(12)      #2    gr2.switch()    #切换    print(34)       #4    gr2.switch()    #切换def test2():    print(56)       #3    gr1.switch()    #切换    print(78)       #5gr1 = greenlet(test1)gr2 = greenlet(test2)gr1.switch()         #1

协程切换原理 遇到IO操作就切换，执行时间短的先执行，(IO 为等待时间)import geventdef foo():    print(‘foo 1‘)   #1    gevent.sleep(2)    print(‘foo 2‘) #6def bar():    print(‘bar 1‘)  #2    gevent.sleep(1)    print(‘bar 2‘) #5def func3():    print("func 1") #3     gevent.sleep(0)    print(‘func 2‘) #4 gevent.joinall([    gevent.spawn(foo),    gevent.spawn(bar),    gevent.spawn(func3),])

#!/usr/bin/env python# _*_ encoding:utf-8 _*_from greenlet import greenletfrom urllib import requestimport gevent,timefrom gevent import monkeymonkey.patch_all()           #把当前程序所有的IO操作做上标记(否则gevent无法识别)def f(url):    print(‘GET: %s‘% url)    resp = request.urlopen(url)    data = http://www.mamicode.com/resp.read()"cost",time.time() - time_start)async_time_start = time.time()gevent.joinall([    gevent.spawn(f,‘https://www.python.org/ ‘),    gevent.spawn(f,‘https://www.yahoo.com/ ‘),    gevent.spawn(f,‘https://github.com/ ‘),])print("cost",time.time() - async_time_start)

server#!/usr/bin/env python# _*_ encoding:utf-8 _*_import sysimport socketimport timeimport geventfrom gevent import socket,monkeymonkey.patch_all()def server(port):    s = socket.socket()    s.bind((‘localhost‘,port))    s.listen(500)    while True:        cli,addr = s.accept()        gevent.spawn(handle_request,cli)def handle_request(conn):    try:        while True:            data = conn.recv(1024)            print(‘recv:‘,data)            conn.send(data)            if not data:                conn.shutdown(socket.SHUT_WR)    except Exception as ex:        print(ex)    finally:        conn.close()if __name__ == ‘__main__‘:    server(8001)clinetimport socketHOST = ‘localhost‘PORT = 8001s = socket.socket(socket.AF_INET,socket.SOCK_STREAM)s.connect((HOST,PORT))while True:    msg = bytes(input(">>"),encoding=‘utf8‘)    s.sendall(msg)    data = http://www.mamicode.com/s.recv(1024)>

对事件做处理 例如：点击鼠标 放到一个时间列表 按键盘放到一个时间列表 有一个进程来处理

服务收到一个事件，会放到对应的列表里面，文件描述符就是对应的索引，而索引对应是文件句柄(文件对象)

程序不可以直接调用系内核，程序打开文件都是调用内核来完成的，例如拷贝文件，是先拷贝到内核缓存区 然后再拷贝到io