pythonNet08

from threading import Thread from time import sleep a = 1 def foo(): global a a = 1000 def bar(): sleep(1) print("a = ",a) t1 = Thread(target = foo) t2 = Thread(target = bar) t1.start() t2.start() t1.join() t2.join() # a = 1000

import threading from time import sleep s = None #共享资源 e = threading.Event() #创建事件对象 def bar(): print("呼叫foo") global s s = "天王盖地虎" def foo(): print("等口令") sleep(2) if s == "天王盖地虎": print("宝塔镇河妖") else: print("打死他") e.set() # 设置事件 def fun(): print("呵呵....") sleep(1) e.wait() # 事件阻塞函数 global s s = "小鸡炖蘑菇" b = threading.Thread(target = bar) # 创建事件对象 f = threading.Thread(target = foo) t = threading.Thread(target = fun) b.start() f.start() t.start() b.join() f.join() t.join() # 呼叫foo # 等口令 # 呵呵.... # 宝塔镇河妖

import threading a = b = 0 lock = threading.Lock() # 创建锁对象 def value(): while True: lock.acquire() #上锁 if a != b: print("a = %d,b = %d"%(a,b)) lock.release() # 解锁 t = threading.Thread(target = value) # 创建线程对象 t.start() while True: lock.acquire() # 上锁 a += 1 b += 1 lock.release() # 解锁 t.join()

#计算密集 def count(x,y): c = 0 while c < 7000000: x += 1 y += 1 c += 1 #io密集 def write(): f = open("test.txt",'w') for x in range(2000000): f.write("hello world\n") f.close() def read(): f = open("test.txt") lines = f.readlines() f.close()

#单进程程序 from test import * import time # t = time.time() # for i in range(10): # count(1,1) # print("Line cpu:",time.time() - t) t = time.time() for i in range(10): write() read() print("Line IO:",time.time() - t)

from test import * import threading import time counts = [] t = time.time() for x in range(10): th = threading.Thread(target = count,args = (1,1)) th.start() counts.append(th) for i in counts: i.join() print("Thread cpu",time.time() - t)

from test import * import threading import time counts = [] def io(): write() read() t = time.time() for x in range(10): th = threading.Thread(target = io) th.start() counts.append(th) for i in counts: i.join() print("Thread IO",time.time() - t)

from test import * import multiprocessing import time counts = [] t = time.time() for x in range(10): th = multiprocessing.Process\ (target = count,args = (1,1)) th.start() counts.append(th) for i in counts: i.join() print("Process cpu",time.time() - t)

from test import * import multiprocessing import time counts = [] def io(): write() read() t = time.time() for x in range(10): th = multiprocessing.Process(target = io) th.start() counts.append(th) for i in counts: i.join() print("Process IO",time.time() - t)

from socket import * import os,signal,sys,time FILE_PATH = "/home/tarena/" #文件库 class TftpServer(object): #实现功能模块 pass #流程控制，创建套接字，创建并发，方法调用 def main(): HOST = '0.0.0.0' PORT = 8888 ADDR = (HOST,PORT) sockfd = socket() sockfd.setsockopt(SOL_SOCKET,SO_REUSEADDR,1) sockfd.bind(ADDR) sockfd.listen(5) signal.signal(signal.SIGCHLD,signal.SIG_IGN) while True: try: connfd,addr = sockfd.accept() except KeyboardInterrupt: sockfd.close() sys.exit("服务器退出") except Exception as e: print(e) continue print("客户端登录:",addr) #创建父子进程 pid = os.fork() # 子进程处理客户端请求，父进程等待其他客户端连接 if pid == 0: sockfd.close() tftp = TftpServer() # __init__传参 while True: data = connfd.recv(1024).decode() if data == "list": tftp.do_list() elif data == 'get': tftp.do_get() elif data == 'put': tftp.do_put() elif data == 'quit': print("客户端退出") sys.exit(0) else: connfd.close() continue if __name__ == "__main__": main()

from socket import * import sys import time class TftpClient(object): #实现各种功能请求 pass #创建套接字建立连接 def main(): if len(sys.argv) < 3: print("argv is error") return HOST = sys.argv[1] PORT = int(sys.argv[2]) ADDR = (HOST,PORT) sockfd = socket() sockfd.connect(ADDR) tftp = TftpClient() #__init__是否需要传参 while True: print("打印界面") cmd = input("输入命令>>") if cmd == "list": tftp.do_list() if __name__ == "__main__": main()