锅得不到缸 发表于 2020-7-1 16:38:08

关于multiprocessing模块

当建立 可接受多个client连接的server的时后:
#服务器端
from multiprocessing import Process
import socket


def talk(conn):# 定义功能
    while True:
      conn.send(b'hello')
      msg = conn.recv(1024).decode('utf-8')
      print(msg)
    conn.close()


s = socket.socket()
s.bind(('127.0.0.1', 9001))
s.listen()

while True:# 每接受一个conn 就实例化一个Process
    conn, addr = s.accept()
    Process(target=talk, args=(conn,)).start()

#客户端1
import socket

c = socket.socket()

c.connect(('127.0.0.1', 9001))
while True:
    c.send(b'im first')
    msg = c.recv(1024).decode('utf-8')
    print(msg)

#客户端2
import socket

c = socket.socket()

c.connect(('127.0.0.1', 9001))
while True:
    c.send(b'im second')
    msg = c.recv(1024).decode('utf-8')
    print(msg)

执行结果为什么会出现 两个服务器的发送内容出现在同一行{:5_91:}

以下为执行结果
im first
im second
im first
im second
im first
im second
im firstim second

im first
im second
im first
im second
im first
im second
im first
im second
im firstim second

im firstim second

im first
im second
im first
im second
im first
im second
im first
im second
im firstim second

im second
im first
im second
im first

赚小钱 发表于 2020-7-1 17:10:38

如果你进一步思考,会发现,出现 im firstim second 的下一行都是空字符串
这是因为 send, recv, print 三个函数,只在当前线程内保证顺序,在多线程之间,不保证顺序。
执行顺序可能出现
线程1: send// send(im first)
线程2: send// send(im second)
线程1: recv   // recv(im first im second)
线程1: print// print(im first im second)
线程2: recv   // recv('')
线程2: print   // print('')

事实上,出现还有很多种情况,能得到你遇到的结果。

锅得不到缸 发表于 2020-7-2 09:15:04

谢谢大佬{:5_95:}
页: [1]
查看完整版本: 关于multiprocessing模块