有效沟通问答-【官方】百战程序员_IT在线教育培训机构

#coding = utf-8
# 一个房子，一次只允许两个人进来
from asyncio import sleep
from threading import Semaphore, Thread


def home(name, se):
    se.acquire()
    print(f"{name},进入房间",)
    sleep(5)
    print(f"########{name},走出房间", )
    se.release()


if __name__ == '__main__':
    se = Semaphore(2)
    for i in range(1, 8):
        t = Thread(target=home, args=(f"tom{i}", se))
        t.start()

Python 全系列/第三阶段：Python 网络与并发编程/并发编程 931楼

两个问题

1、老师这个“f”是什么作用呢

还有这个{name} 的值是吧t1、 t2传给了它吗

Python 全系列/第三阶段：Python 网络与并发编程/并发编程 932楼

TCP多线通信问题.docx

def recv_data():
while True:
# 接收服务器端数据
recv_data = client_socket.recv(1024)
recv_content = recv_data.decode('gbk')
print(f"服务端说：{recv_content}")
if recv_content == "end":
print("结束接收消息")
break

def send_data():
while True:
# 给服务端发消息
msg = input(">")
client_socket.send(msg.encode('gbk'))
if msg == "end":
break

if __name__ == '__main__':
client_socket = socket(AF_INET, SOCK_STREAM)
client_socket.connect(("127.0.0.1", 8899))

t1 = Thread(target=recv_data)
t2 = Thread(target=send_data)
t1.start()
t2.start()

client_socket.close()

# coding=utf-8
from socket import *
from threading import Thread

def recv_data():
while True:
recv_data = client_socket.recv(1024)
recv_content = recv_data.decode('gbk')
print(f"客户端说：{recv_content},来自{client_info}")
if recv_content == "end":
print("结束接收消息")
break

def send_data():
while True:
msg = input(">")
client_socket.send(msg.encode('gbk'))
if msg == "end":
print("结束发送消息！")
break

if __name__ == '__main__':
server_socket = socket(AF_INET, SOCK_STREAM)
server_socket.bind(("127.0.0.1", 8899))
server_socket.listen(5)
print("等待接收连接！")
client_socket,client_info = server_socket.accept()
print("一个客户端建立连接成功！")
t1 = Thread(target=recv_data)
t2 = Thread(target=send_data)
t1.start()
t2.start()

t1.join()
t2.join()

client_socket.close()
server_socket.close()

Python 全系列/第三阶段：Python 网络与并发编程/网络通信 933楼

老师为什么视频在讲队列时只用到了单线程啊，那队列在多线程中怎么体现？？？？？？？

Python 全系列/第三阶段：Python 网络与并发编程/并发编程 934楼

老师，我们一定要安装code.exe这个软件吗？用pycharm不可以吗

Python 全系列/第三阶段：Python 网络与并发编程/并发编程 935楼

老师，这个怎么改啊

Python 全系列/第三阶段：Python 网络与并发编程/并发编程 936楼

在mac下会报错没有join的情况，为什么报如下的错误:

Traceback (most recent call last):

File "<string>", line 1, in <module>

File "/Library/Frameworks/Python.framework/Versions/3.8/lib/python3.8/multiprocessing/spawn.py", line 116, in spawn_main

Traceback (most recent call last):

File "<string>", line 1, in <module>

exitcode = _main(fd, parent_sentinel)

File "/Library/Frameworks/Python.framework/Versions/3.8/lib/python3.8/multiprocessing/spawn.py", line 126, in _main

File "/Library/Frameworks/Python.framework/Versions/3.8/lib/python3.8/multiprocessing/spawn.py", line 116, in spawn_main

self = reduction.pickle.load(from_parent)

File "/Library/Frameworks/Python.framework/Versions/3.8/lib/python3.8/multiprocessing/synchronize.py", line 110, in __setstate__

exitcode = _main(fd, parent_sentinel)

File "/Library/Frameworks/Python.framework/Versions/3.8/lib/python3.8/multiprocessing/spawn.py", line 126, in _main

self = reduction.pickle.load(from_parent)

File "/Library/Frameworks/Python.framework/Versions/3.8/lib/python3.8/multiprocessing/synchronize.py", line 110, in __setstate__

self._semlock = _multiprocessing.SemLock._rebuild(*state)

FileNotFoundError: [Errno 2] No such file or directory

self._semlock = _multiprocessing.SemLock._rebuild(*state)

FileNotFoundError: [Errno 2] No such file or directory

Traceback (most recent call last):

File "<string>", line 1, in <module>

File "/Library/Frameworks/Python.framework/Versions/3.8/lib/python3.8/multiprocessing/spawn.py", line 116, in spawn_main

exitcode = _main(fd, parent_sentinel)

File "/Library/Frameworks/Python.framework/Versions/3.8/lib/python3.8/multiprocessing/spawn.py", line 126, in _main

self = reduction.pickle.load(from_parent)

File "/Library/Frameworks/Python.framework/Versions/3.8/lib/python3.8/multiprocessing/synchronize.py", line 110, in __setstate__

self._semlock = _multiprocessing.SemLock._rebuild(*state)

FileNotFoundError: [Errno 2] No such file or directory

Python 全系列/第三阶段：Python 网络与并发编程/并发编程 937楼

老师您好，这里我可以理解成这个socket函数传入参数后，返回的是一个对象，这样理解可以吗？

Python 全系列/第三阶段：Python 网络与并发编程/网络通信 938楼

老师为什么我运行的是10个一起出结果，sleep 3秒后程序结束

# ！/user/bin/env python3
# -*- coding: utf-8 -*-

from threading import Thread
from threading import BoundedSemaphore
from time import sleep

def an_jian(num):
    semaphore.acquire()
    print(f'第{num}个人通过安检')
    sleep(3)
    semaphore.release()

if __name__ == '__main__':
    semaphore=BoundedSemaphore(10)
    for i in range(10):
        t = Thread(target=an_jian,args=(f'{i+1}',))
        t.start()

Python 全系列/第三阶段：Python 网络与并发编程/并发编程 939楼

Python 全系列/第三阶段：Python 网络与并发编程/网络通信 940楼

一、代码

#coding=utf-8

import threading
import time
from queue import Queue

class Pro(threading.Thread):
    def run(self):
        global q
        count=0
        while True:
            if q.qsize()<100:
                for i in range(10):
                    count = count+1
                    msg = "生成产品"+str(count)
                    q.put(msg)
                    print(msg)
            time.sleep(1)

class Con(threading.Thread):
    def run(self):
        global q
        while True:
            if q.qsize()>10:
                for i in range(3):
                    msg = self.name + "消费了" + q.get()
                    print(msg)
            time.sleep(1)


if __name__ == "__main__":
    q = Queue()
    for i in range(50):
        q.put("初始产品"+str(i))
        print("初始产品"+str(i))
    for i in range(2):
        p = Pro()
        p.start()
    for i in range(5):
        c = Con()
        c.start()

二、运行结果

生成产品1

生成产品2

生成产品3

生成产品4

生成产品5

生成产品6

生成产品7

生成产品8

生成产品9

生成产品10

Thread-3消费了初始产品0

Thread-3消费了初始产品1

Thread-3消费了初始产品2

Thread-4消费了初始产品3

Thread-4消费了初始产品4

Thread-4消费了初始产品5

Thread-5消费了初始产品6

Thread-5消费了初始产品7

Thread-5消费了初始产品8

Thread-6消费了初始产品9

Thread-6消费了初始产品10

Thread-6消费了初始产品11

Thread-7消费了初始产品12

Thread-7消费了初始产品13

Thread-7消费了初始产品14

Thread-4消费了初始产品15

Thread-4消费了初始产品16

Thread-4消费了初始产品17

生成产品11

生成产品12

生成产品13

生成产品14

生成产品15

生成产品16

Thread-3消费了初始产品18

Thread-3消费了初始产品19

Thread-3消费了初始产品20

生成产品11

生成产品12

生成产品13

生成产品14

生成产品17

生成产品18

生成产品19

生成产品20

生成产品15

生成产品16

生成产品17

Thread-7消费了初始产品21

Thread-6消费了初始产品22

Thread-6消费了初始产品23

Thread-6消费了初始产品24

Thread-7消费了初始产品25

生成产品18

生成产品19

Thread-7消费了初始产品26

Thread-5消费了初始产品27

Thread-5消费了初始产品28

Thread-5消费了初始产品29

生成产品20

Thread-4消费了初始产品30

Thread-4消费了初始产品31

Thread-4消费了初始产品32

Thread-3消费了初始产品33

Thread-3消费了初始产品34

Thread-3消费了初始产品35

Thread-5消费了初始产品36

Thread-5消费了初始产品37

Thread-5消费了初始产品38

Thread-6消费了初始产品39

Thread-6消费了初始产品40

Thread-6消费了初始产品41

生成产品21

生成产品22

生成产品23

生成产品24

生成产品25

生成产品26

生成产品27

生成产品28

生成产品21

生成产品22

生成产品23

生成产品24

生成产品25

生成产品26

生成产品27

Thread-7消费了初始产品42

Thread-7消费了初始产品43

Thread-7消费了初始产品44

生成产品29

生成产品30

三、问题

上述程序创造了2个产生数据的线程p1、p2，和五个输出数据的线程c1/2/3/4/5，产生数据的线程是一个循环，产生10个数据，消费数据的线程是输出3个线程，我知道线程之间是交替执行的，但是从结果中看出，一个线程的循环都没有结束都跳去了另一个线程里呢，而且还没有规律，请问老师这样是为什么？线程交替运行这么不可控，他存在的意思是啥，都不能用来计算？

Python 全系列/第三阶段：Python 网络与并发编程/并发编程 941楼

Process.__init__(self)

老师你好！这个是不是可以这样理解呢，老师（如下）

class Process():
    def __init__(self):

谢谢老师！

Python 全系列/第三阶段：Python 网络与并发编程/并发编程 942楼

#coding=utf-8
from threading import Thread
from time import sleep

def func1(name):
    print(f"线程{name},start")#format
    for i in range(3):
        print(f"线程: {name},{i}")
        sleep(3)
    print(f"线程{name},end")


if __name__ == '__main__':
    print("主线程,start")
    #创建线程
    t1 = Thread(target=func1,args=("t1"))
    t2 = Thread(target=func1,args=("t2"))
    #启动线程
    t1.start()
    t2.start()
    print("主线程,end")

老师为什么我这个运行不了

Python 全系列/第三阶段：Python 网络与并发编程/并发编程 943楼

代码如下:

multiprocessing ProcessQueue
time sleep


MyProcess(Process):
    (namemq):
        Process.()
        .name = name
        .mq = mq

    ():
        (.name)
        (.mq.get())
        sleep()
        (.name)


__name__ == :
    mq = Queue()
    mq.put()
    mq.put()
    mq.put()
    p_list=[]
    i ():
        p = MyProcess(imq)
        p_list.append(p)

    p p_list:
        p.start()

Python 全系列/第三阶段：Python 网络与并发编程/并发编程 944楼

老师，请问图中的变量recv_data[0]前面的3和1各占两个字节，不应该是从第5位开始才是图片的数据吗？即[5:]；还是说在这里遵循不包头包尾呀？

Python 全系列/第三阶段：Python 网络与并发编程/网络通信 945楼

同学您好