# -*- coding: utf-8 -*-

"""

多进程 数据共享 共享变量 Value,Array

逻辑:

2个进程，对同一份数据，一个做加法，一个做加法，各做10次

用法:

1. 创建共享变量 o = Value(‘i‘,1000) or o = Array(‘i‘,list) 指定不同的类型

2. 启动子进程通过 o.value or o[i] 存取变量的值

3. 必要使用锁操作函数 o.acquire() o.release()

参考:

get_lock() 返回共享变量使用的Rlock 实例

get_obj() 返回共享变量数据类型

"""

from multiprocessing import Process,Value,Array

import time

import random

# 对共享变量加法

def save_money(money):

money.acquire() # 申请锁

for i in range(10):

time.sleep(0.3)

change = random.randint(1,200)

money.value += change

print "\n ",money.value,change

money.release() # 释放锁

# 对共享变量减法

def take_money(money):

money.acquire()

for i in range(10):

time.sleep(0.5)

change = random.randint(1,150)

money.value -= change

print "\n ",money.value," ",-change

money.release()

# 对共享变量加法

def save_money2():

m.acquire() # 申请锁

m[2] = 8

print [ i for i in m ]

m.release() # 释放锁

# 对共享变量减法

def take_money2():

m.acquire() # 申请锁

print [ i for i in m ]

m.release() # 释放锁

if True:

m = Array(‘i‘,[1,2,3,4,5]) # 放在main下面，就不是全局了

if __name__ == ‘__main__‘:

# 共享内存，可以多个进程存取,整型，变量名money,变量值1000

money = Value(‘i‘,1000)

d = Process(target=save_money, args=(money,))

d.start()

w = Process(target=take_money, args=(money,))

w.start()

d.join()

w.join()

Process(target=save_money2).start()

Process(target=take_money2).start()

print "end"