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

import threading
from socket import *

b = socket(AF_INET, SOCK_DGRAM)

def receivedate():          # 接受数据
    global b
    b.bind(("", 7890))
    while True:
        recv_date = b.recvfrom(1024)
        print(recv_date[0].decode())


def senddate():               # 打印数据
    while True:
        date = input("请输入：")
        print(date)
        b.sendto(date.encode(), receivedate().recv_date[1])


if __name__ == '__main__':
    t1 = threading.Thread(target=receivedate)
    t2 = threading.Thread(target=senddate)
    t1.start()
    t2.start()

    b.close()

老师，这个聊天窗口怎么写，我一直错误

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

老师，请问，资料上讲，这段代码有IO，是单纯的切换，没有提高效率，疑问是：这段代码的IO体现在哪里呢

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

print(f"Treading:{name} start")
t1 = Thread(target=func1,args=('t1',))
t2 = Thread(target=func1,args=('t2',))

老师，您能帮我解释一下第一行代码的意思嘛？

第二和第三行代码的target和args是什么意思呢？这几行代码的格式是固定的吗？

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

老师，一个类中，可以用多线程吗？如果可以，怎么使用？

import threading
from socket import *


class chatwin():
    b = socket(AF_INET, SOCK_DGRAM)
    b.bind(("", 7890))

    def receivedate(self):          # 接受数据
        while True:
            global b
            self.recv_date = b.recvfrom(1024)
            print(self.recv_date[0].decode())

    def senddate(self):               # 打印数据
        while True:
            date = input("请输入：")
            print(date)
            b.sendto(date.encode(), self.recv_date[1])


    if __name__ == '__main__':
        t1 = threading.Thread(target=receivedate)
        t2 = threading.Thread(target=senddate)
        t1.start()
        t2.start()

    b.close()

我一直是错的,

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

老师，请问，下载gevent的时候出错了

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

#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 网络与并发编程/并发编程 937楼

两个问题

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

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

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

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 网络与并发编程/网络通信 939楼

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

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

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

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

老师，这个怎么改啊

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

在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 网络与并发编程/并发编程 943楼

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

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

老师为什么我运行的是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 网络与并发编程/并发编程 945楼

同学您好