from multiprocessing import Process,Queue
import time


def write(q):
    for value in ["a", "b", "c"]:
        print("开始写入", value)
        q.put(value)
        time.sleep(1)


def read1(q):
    for x in range(3):
        a = q.get()
        print("读取到的值是： ", a)
        q.put(a)
        time.sleep(1)

def read2(q):
    while True:
        if not q.empty():
            print("read2读取到是数字是： ", q.get())
            time.sleep(1)
        else:
            break


if __name__ == '__main__':
    q = Queue()
    pw = Process(target=write, args=(q,))
    pr1 = Process(target=read1, args=(q,))
    pr2 = Process(target=read2, args=(q,))
    pw.start()
    pw.join()
    pr1.start()
    pr1.join()
    pr2.start()
    pr2.join()
    print("OVER")

如果有2个接收方怎么办？python3.7，这个还能优化吗？

老师，queue中的消息，是有序的吗？还是无序的？

如果有2个接收方怎么办？python3.7

from multiprocessing import Process,Queue
import time


def write(q):
    for value in ["a", "b", "c"]:
        print("开始写入", value)
        q.put(value)
        time.sleep(1)


def read(q):
    while True:
        if not q.empty():
            print("读取到的值是： ", q.get())
            time.sleep(1)
        else:
            break


if __name__ == '__main__':
    q = Queue()
    pw = Process(target=write, args=(q,))
    pr = Process(target=read, args=(q,))
    pw.start()
    pw.join()
    pr.start()
    pr.join()
    print("OVER")

老师，Queue，中的消息，是有顺序的吗？还是无序的？

老师，这些进程，都是做什么用的？学这些，的目的是什么？

from multiprocessing import Process
num = 1
def run1():
    global num
    num += 15
    print("子进程1的数字是：%d"%num)
def run2():
    global num
    num += 100
    print("子进程2的数字是：%d"%num)

if __name__ == '__main__':
    print("父进程启动")
    p = Process(target=run1, name="one1")
    p1 = Process(target=run2, name="two2")
    print("开始执行子程序")
    p.start()
    p1.start()
    p.join()
    p1.join()
    print(num)
    print("进程结束")

老师，我运算的结果，为什么是这样的？

为什么我的跟老师的不一样，我的没有老师说的那个问题

视频中代码：

# 进程间通信练习
import time
from multiprocessing import Process, Queue


def write():  # 这里不需要传参数q
    for value in ["a", "b", "c"]:
        print("start writing:", value)
        q.put(value)
        time.sleep(1)


def read():   # 这里不需要传参数q
    while True:
        if not q.empty():
            print("读取到的是", q.get())
            time.sleep(1)
        else:
            break


if __name__ == '__main__':
    q = Queue()
    q1 = Queue()
    pw = Process(target=write)
    pr = Process(target=read)
    pw.start()
    pw.join()  # 等待接收完毕，等待write()函数执行完毕
    pr.start()
    pr.join()
    print("接收完毕！")

write()和read()函数不需要传详细队列对象参数q，也能正常运行得到相同的结果。所以函数传q这个参数不是必须的吗？

这是上面代码运行的结果：

for i in range(10):
    po.apply_async(work, (i,))

按照视频讲解，for循环创建10个子进程之后，

po.close()  # 进程池关闭之后不再接收新的请求

上面语句执行之后，不再接收新的请求，但是已经创建的子进程还是要等待进入Pool运行，是这样理解吧？

老师我想问一下为什么下载会文件不存在

#coding=utf-8
import struct
from socket import *
filename = 'test.jpg'
server_ip = "192.168.56.1"
send_data = struct.pack('!H%dsbsb'%len(filename),1,filename.encode(),0,'octet'.encode(),0)
s= socket(AF_INET,SOCK_DGRAM)
s.sendto(send_data,(server_ip,69))
f= open(filename,'ab')
while True:
    recv_data=s.recvfrom(1024)
    print(recv_data)
    caozuoma,ack_num=struct.unpack('!HH',recv_data[0][:4])
    rand_port=recv_data[1][1]
    if int(caozuoma)==5:
        print("文字不存在")
        break
    print("操作码: %d ACK: %d,服务器随机端口: %d,数据长度: %d"%(caozuoma,ack_num,rand_port,len(recv_data)))
    f.write(recv_data[0][4:])
    if len(recv_data[0])<516:
        break
    ack_num =struct.pack("!HH",4,ack_num)
    s.sendto(ack_num,(server_ip,rand_port))

import socket

s = socket.socket(socket.AF_INET, socket.SOCK_DGRAM)  # udp协议
# 发数据
s.bind(('', 8985))

s.sendto('你好'.encode(), (' ', 8585))
res = s.recvfrom(1024)
print(res[0].decode())

老师 ，我这个提示这个错误是怎么回事哈，

老师，我想请问为什么同样的结构，文件名为英文名就可以成功，文件名为中文名就会报错：

代码：

from socket import *
import struct

fileName = '焰灵姬.jpg'
adrr = '192.168.0.107'
cmb_buf = struct.pack('!H%dsb5sb'%len(fileName),1,fileName.encode('gbk'),0,'octet'.encode('gbk'),0)
s = socket(AF_INET,SOCK_DGRAM)
s.sendto(cmb_buf,(adrr,69))
f = open(fileName,'ab')
while True:
    recvdata = s.recvfrom(1024)
    caozuoma,ack_number = struct.unpack('!HH',recvdata[0][:4])
    rand_port = recvdata[1][1]
    if int(caozuoma) == 5:
        print('文件出错')
        break
    f.write(recvdata[0][4:])
    if len(recvdata[0]) < 516:
        print('文件传输完毕')
        break
    ack_data = struct.pack('!HH',4,ack_number)
    s.sendto(ack_data,(adrr,rand_port))

老师，我想请问为什么文件名为中文名就会报错。

请问老师，多线程是在一个CPU上执行，还是在多个cpu切换执行

老师您好，在学完线程同步后我也查了下异步相关的资料，即“同步有序、异步无序”，那么在不用锁等方式进行同步的情况下，默认是不是就是异步的？

/////////软件汉化包粘贴到什么地方？

老师您好，您能给总结下echo的作用么？比如之后一个大项目里的作用，因为我网上找了下，相关的介绍不多。