python进程开发

qq489498494

　　程序并不能单独运行，只有将程序装载到内存中，系统为它分配资源才能运行，而这种执行的程序就称之为进程。程序和进程的区别就在于：程序是指令的集合，它是进程运行的静态描述文本；进程是程序的一次执行活动，属于动态概念。
　　进程只能在一个时间干一件事，如果想同时干两件事或多件事，进程就无能为力了。
　　进程在执行的过程中如果阻塞，例如等待输入，整个进程就会挂起，即使进程中有些工作不依赖于输入的数据，也将无法执行。
　　进程和线程的主要差别在于它们是不同的操作系统资源管理方式。进程有独立的地址空间，一个进程崩溃后，在保护模式下不会对其它进程产生影响，而线程只是一个进程中的不同执行路径。线程有自己的堆栈和局部变量，但线程之间没有单独的地址空间，一个线程死掉就等于整个进程死掉，所以多进程的程序要比多线程的程序 健壮，但在进程切换时，耗费资源较大，效率要差一些。但对于一些要求同时进行并且又要共享某些变量的并发操作，只能用线程，不能用进程。
　　例子：
#!/usr/local/python27/bin/python2.7# coding=utf8# noinspection PyUnresolvedReferences from multiprocessing import Processimport time def f(n):    time.sleep(1)    print n*n for i in range(10):    p = Process(target=f,args=[i,])    p.start()　　在一般情况下多个进程的内存资源是相互独立的，而多线程可以共享同一个进程中的内存资源，示例代码：
#!/usr/local/python27/bin/python2.7# coding=utf8# noinspection PyUnresolvedReferences# 通过多进程和多线程对比，进程间内存无法共享，线程间的内存共享from multiprocessing import Processimport threadingimport timelock = threading.Lock() def run(info_list,n):    lock.acquire()    info_list.append(n)    lock.release()    print('%s\n' % info_list) info = [] for i in range(10):'''target为子进程执行的函数，args为需要给函数传递的参数'''        p = Process(target=run,args=[info,i])    p.start() '''这里是为了输出整齐让主进程的执行等一下子进程'''    time.sleep(1)    print('------------threading--------------') for i in range(10):    p = threading.Thread(target=run,args=[info,i])    p.start()　　进程间通信：
#!/usr/local/python27/bin/python2.7# coding=utf8# noinspection PyUnresolvedReferences# 通过multiprocessing.Queue实现进程间内存共享from multiprocessing import Process,Queueimport time def write(q):    for i in ['A','B','C','D','E']:        print('Put %s to queue' % i)        q.put(i)        time.sleep(0.5) def read(q):    while True:        v = q.get(True)        print('get %s from queue' %v) if __name__ == '__main__':    q = Queue()    pw = Process(target=write,args=(q,))    pr = Process(target=read,args=(q,))    pw.start()    pr.start()    pr.join()    pr.terminate()　　进程池：
#!/usr/local/python27/bin/python2.7# coding=utf8# noinspection PyUnresolvedReferencesfrom multiprocessing import Poolimport time def f(x):    print x*x    time.sleep(2)    return x*x '''定义启动的进程数量'''pool = Pool(processes=5)res_list = [] for i in range(10):    '''以异步并行的方式启动进程，如果要同步等待的方式，可以在每次启动进程之后调用res.get()方法，也可以使用Pool.apply'''    res = pool.apply_async(f,[i,])    print('-------:',i)    res_list.append(res)pool.close()pool.join()for r in res_list:    print(r.get(timeout=5))