I/O 操作

input() ----3.x 版本取消了raw_input()---input函数只能返回字符串
open() ----函数返回一个打开的对象
read() ----方法读取打开的对象，但是读取一次后就不能再读取
write() ----给打开的对象写入内容

try:
except: ----如果try为真则不执行except 的值

try：
finally： ----如果try为真也要执行finally的值【读写文件的时候需要finally来释放内存close】

with open('a.txt',‘w’) as f:
f.write() ----##with 可以释放内存，也就是相当于多了一个f.close()

f.readlines()---##作为一个列表读取每一行
f.readline()---##只读取一行

操作文件和目录

os.getcwd() --##获得当前目录
os.remove()--##删除文件
os.chdir() ---##更改目录

序列化

存储变量一种是通过文件读写的方式，这种方式得控制格式。pickle模块可以直接把对象通过序列化存储下来，下次程序运行时再拿出来。

d=dict(url='index.html',title='shouye',content='pcikle')
f=open(r'c:\users\chenwen1\45.txt','wb')
pickle.dump(d,f)
f.close()

反序列化通过pickle.load()

多进程

multiprocessing
Process
多进程不能在python IDLE中运行

import os
import time
from multiprocessing import Process

def run_proc(name):
     print('Child process %s(%s) Running...'%(name,os.getpid()))  ##这种输出方式

 if __name__=='__main__':
     print('Parent process %s.'%os.getpid())   ##os.getpid()获得进程号
     for i in range(5):
        p=Process(target=run_proc,args=(str(i),))     ##生成一个新的进程【target是进程的事情，args是函数参数是元组】
        print('Process will start')
        p.start()     ##开始进程
        p.join()      ##阻止主程序运行
        print('Process end')
        ***如果是没有p.join(),则会主程序运行完成以后再运行进程***

Pool库（子进程资源库）

import os
import time
import random
from multiprocessing import Pool
def run_task(name):
      print('Task %s(pid=%s) is running...'%(name,os.getpid()))
time.sleep(1)
print('Task %s end'%name)

if __name__=='__main__':
      print('Current process %s'%os.getpid())
p=Pool(processes=3)     #子进程最多运行3个
for i in range(5):
    p.apply_async(run_task , args=(str(i),))    #开始子进程
print('waiting foa all subprocesses done...')
p.close()     # 资源池不能再添加新的子进程【会把self.state的状态改为close,join函数运行的前提是状态不为run】
p.join()   #主进程等待子进程

print('ALL subprocesses done')

进程间的通信

通过队列（Queue）

import os
import time
import random
from multiprocessing import Process , Queue
def proc_write(q,urls):
    print('Process(%s) is Running..'%os.getpid())     
    for url in urls:
        q.put(url)     #往队列中加入对象
        print('Put %s to queue...'%url)
        time.sleep(random.random())
def proc_read(q):
    print('Process(%s) is reading...'%os.getpid())
    while True:
        url=q.get(True)    #从队列中读取对象并删除
        print('Get %s from queue.'%url)

if __name__=='__main__':
    q=Queue()   #创建队列再进程中
    proc_write1 = Process(target = proc_write,args=(q,['url_1','url_2','url_3']))  #队列对象作为参数传给子进程
    proc_write2 = Process(target = proc_write,args=(q,['url_4','url_5','url_6']))
    proc_reader = Process(target = proc_read,args=(q,))
    proc_write1.start()
    proc_write2.start()
    proc_reader.start()
    proc_write1.join()
    proc_write2.join()
    proc_reader.terminate()

通过管道（Pipe）

import multiprocessing
import random
import time,os
def proc_send(pipe,urls):
    for url in urls:
        print('Procesing(%s)send:%s'%(os.getpid(),url))
        pipe.send(url)##向管道中送入数据
        time.sleep(random.random())

def proc_recv(pipe):
     while True:
        print('Process(%s) rev.%s'%(os.getpid(),pipe.recv()))##从管道中接收数据
        time.sleep(random.random())

if __name__ == '__main__':
    pipe = multiprocessing.Pipe()##创建管道
    p1=multiprocessing.Process(target = proc_send,args=(pipe[0],['url_'+str(i) for i in range(10)]))##使用第一个参数
    p2=multiprocessing.Process(target=proc_recv,args=(pipe[1],))##使用第二个参数
    p1.start()
    p2.start()
    p1.join()
    p2.join()

多线程

第一种和多进程有点像

---

import random
import time
import threading
def thread_run(urls):
   print('Current %s is running...'%threading.current_thread().name)
   for url in urls:
    print('%s ---->>>>%s'%(threading.current_thread().name,url))
    time.sleep(random.random())
    print('%s ended'%threading.current_thread().name)
    print('%s is running...'%threading.current_thread().name)

t1=threading.Thread(target=thread_run,name='Thread_1',args=(['url_1','url_2','url_3'],))#创建
t2=threading.Thread(target=thread_run,name='Thread_2',args=(['url_4','url_5','url_6'],))#创建
t1.start()
t2.start()
t1.join()
t2.join()

第二种利用类的方法：

---

首先介绍类
类的继承（比如student类继承people类）

class Student（people）:
    def  __init__(self,name,age,sex,salary):
         people.__init__(self,name,age,sex)
         self.salary=salary

---

---

import random
import threading
import time
class myThread(threading.Thread):
    def __init__(self,name,urls):
        threading.Thread.__init__(self,name=name)  ##这里相当于把前面那几行用这一行代替
        self.urls=urls

    def run(self):
        print('Current %s is running...'%threading.current_thread().name)
        for url in self.urls:   ##这里必须用self.urls
            print('%s ---->>>>%s'%(threading.current_thread().name,url))
            time.sleep(random.random())
        print('%s ended'%threading.current_thread().name)

print('%s is runnin...'%threading.current_thread().name)
t1 = myThread(name='Thread_1', urls=['url_1', 'url_2', 'url_3'])
t2 = myThread(name='Thread_2', urls=['url_4', 'url_5', 'url_6'])
t1.start()
t2.start()
t1.join()
t2.join()