"""
pipe.py 管道通信
注意
1. multiprocessing 中管道通信只能用于有親緣關(guān)系進(jìn)程中
2. 管道對(duì)象在父進(jìn)程中創(chuàng)建,子進(jìn)程通過(guò)父進(jìn)程獲取
"""
from multiprocessing import Process, Pipe

# 創(chuàng)建 管道
fd1, fd2 = Pipe()
def app1():
    print('1 啟動(dòng)應(yīng)用1,請(qǐng)登錄')
    print('2 請(qǐng)求app2授權(quán)')
    fd1.send('app1 請(qǐng)求登錄')
    data = fd1.recv()
    print('5 ??',data)
    if data:
        print('6 登錄成功:', data)


def app2():
    print('2.5')
    # 阻塞等待讀取管道內(nèi)容
    data = fd2.recv()
    print('3 app2', data)
    fd2.send(('Dave', '123'))
    print('4 app2,發(fā)送完畢')


if __name__ == '__main__':
    print(-5)
    p1 = Process(target=app1)
    print(-4)
    p2 = Process(target=app2)
    print(-3)
    p1.start()
    print(-2)
    p2.start()
    print(-1)
    p1.join()
    print(0)
    p2.join()
    print('運(yùn)行結(jié)束')
"""
運(yùn)行結(jié)果
(base) [root@VM-0-12-centos pipe]# python pipe.py
-5
-4
-3
-2
-1
1 啟動(dòng)應(yīng)用1,請(qǐng)登錄
2 請(qǐng)求app2授權(quán)
2.5
3 app2 app1 請(qǐng)求登錄
4 app2,發(fā)送完畢
5 ?? ('Dave', '123')
6 登錄成功: ('Dave', '123')
0
運(yùn)行結(jié)束

"""

"""
quque_test.py 消息隊(duì)列演示
注意: 消息隊(duì)列符合先進(jìn)先出原則
"""

# 創(chuàng)建消息隊(duì)列
from multiprocessing import Queue, Process
from random import randint

# 以下模擬 雙色球
# 創(chuàng)建消息隊(duì)列
q = Queue(5)

def handle():
    print(5)
    for i in range(6):
        q.put(randint(1, 33))
    q.put(randint(1, 16))

def request():
    print(6)
    l = [q.get() for i in range(6)]
    l.sort()
    l.append(q.get())
    print(7,l)

if __name__ == '__main__':
    print(0)
    p1 = Process(target=handle)
    print(1)
    p2 = Process(target=request)
    print(2)
    p1.start()
    print(3)
    p2.start()
    print(4)
    p1.join()
    p2.join()
    print(8)
    print('程序結(jié)束')

from multiprocessing import Value,Array

obj = Value(ctype,data)
功能: 開(kāi)辟共享內(nèi)存
參數(shù): ctype 表示共享內(nèi)存空間類型 'i' 'f' 'c'
	data 共享內(nèi)存空間初始數(shù)據(jù)
返回值: 共享內(nèi)存對(duì)象

obj.value 對(duì)象屬性的修改查看即對(duì)共享內(nèi)存讀寫(xiě)

obj = Array(ctype,data)
功能: 開(kāi)辟共享內(nèi)存
參數(shù): ctype 表示共享內(nèi)存空間類型 'i' 'f' 'c'
	data 整數(shù)表示開(kāi)辟空間的大小,其數(shù)據(jù)表示開(kāi)辟空間
返回值: 共享內(nèi)存對(duì)象

Array共享內(nèi)存讀寫(xiě):通過(guò)遍歷obj可以得到每個(gè)值,直接通過(guò)索引可以修改

* 可以使用obj.value 直接打印共享內(nèi)存中的字節(jié)串

"""
value.py 開(kāi)辟單一共享內(nèi)存空間
注意:共享內(nèi)存只能有一個(gè)值
"""

from multiprocessing import Value,Array,Process


import time
import random
ctype = 'i'
data = 5000
# 創(chuàng)建共享內(nèi)存
money = Value(ctype,data)

# 操作共享內(nèi)存
def man():
    for i in range(30):
        time.sleep(0.1)
        money.value += random.randint(1,1000)
        print('man',money.value)

def girl():
    for i in range(30):
        time.sleep(0.1)
        money.value -= random.randint(1,800)
        print('girl', money.value)

if __name__ == '__main__':
    p1 = Process(target=man)
    p2 = Process(target=girl)
    p1.start()
    p2.start()
    p1.join()
    p2.join()
    print('程序結(jié)束',money.value)

"""
array.py 開(kāi)辟單一共享內(nèi)存空間
注意:共享內(nèi)存只能有一個(gè)值
"""

from multiprocessing import Array,Process


ctype = 'i'
data = [1,2,3,4]
# 創(chuàng)建共享內(nèi)存
# shm = Array(ctype,data)

# 表示初始值 [0,0,0,0,0]
shm = Array(ctype,5)


def fun():
    for i in shm:
        print(i)
    shm[1] = 1000
if __name__ == '__main__':
    p1 = Process(target=fun)
    p1.start()
    p1.join()
    print('程序結(jié)束',shm[1])

from multiprocessing import Semaphore

sem = Semaphore(num)
功能: 創(chuàng)建信號(hào)量對(duì)象
參數(shù): 信號(hào)量的初始值
返回值: 信號(hào)量對(duì)象

sem.acquire() 信號(hào)量減1 當(dāng)信號(hào)量為0時(shí)阻塞
sem.release() 信號(hào)量加1
sem.get_value() 獲取信號(hào)量數(shù)量

"""
信號(hào)量.py 信號(hào)量演示
思路: 信號(hào)量數(shù)量相當(dāng)于資源,執(zhí)行任務(wù)必須消耗資源
"""
import os
from multiprocessing import Semaphore
from multiprocessing import Process
from time import sleep

num = 3
sem = Semaphore(num)


# 任務(wù)函數(shù)
def handle():
    sem.acquire()  # sem -1
    print("%s 開(kāi)始執(zhí)行任務(wù)" % os.getpid())
    sleep(3)
    print("%s 執(zhí)行任務(wù)完畢" % os.getpid())
    sem.release()  # sem +1


if __name__ == '__main__':
    ths = []
    for i in range(10):
        p = Process(target=handle)
        p.start()
        ths.append(p)

    for p in ths:
        p.join()
    print('程序結(jié)束')