会员可以在此提问,百战程序员老师有问必答
对大家有帮助的问答会被标记为“推荐”
看完课程过来浏览一下别人提的问题,会帮你学得更全面
截止目前,同学们一共提了 132647个问题
Python 全系列/第三阶段:Python 网络与并发编程/并发编程 783楼

#coding=UTF-8

from threading import Thread, Event
from time import sleep
from random import randint


def door():
    global state
    while True:
        if even.is_set():#如果even事件为真,则执行
            print('我是门:门开着,可以通行~')
            sleep(1)
        else:
            print('我是门:门关了~请刷卡!')
            state = 0#门已关闭,开门循环重置为0
            even.wait()#even事件为等待,进程暂停
        if state > 3:#state在3次循环后
            print('我是门:超过3 秒,门自动关门')
            even.clear() #even事件为假,所有even.wait()发挥作用,将进程暂停
        state +=1#循环一次,state+1,控制门开启时间
        sleep(1)#线程暂停1秒,控制循环时间
def person():
    global state
    n = 0#人员编号
    while True:
        if even.is_set():
            print('我是人:门开着:{}号进入'.format(n))
        else:
            even.set()#将even事件标记为真
            state = 0#开门循环重置为0
            print('我是人:门关着,{}号人刷卡进门'.format(n))
        n += 1
        sleep(randint(1, 10))#随机1-10米秒来一个人,模拟刷卡
if __name__ == '__main__':
    state = 0
    even = Event()
    even.set()
    d = Thread(target=door)
    d.start()
    p = Thread(target=person)
    p.start()

老师,在执行的时候应该先提示

我是门:门关了~请刷卡!

但是我的这个程序,直接就是开着门的,请帮忙看看问题在哪里,谢谢

图片.png

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

#coding=utf-8

from socket import *
from threading import Thread


def recv_data():
   while True:
       recv_data = client_scoket.recv(1024)
       print(f"收到信息:{recv_data.decode('gbk')},来自:

截屏2023-06-30 18.19.04.png

{client_info}")
       if recv_data == "end":
           break


def send_data():
   while True:
       msg = input(">")
       client_scoket.send(msg.encode("gbk"))

if __name__ == "__main__":
   server_socket = socket(AF_INET, SOCK_DGRAM)  # 建立TCP套接字
   server_socket.bind("127.0.0.1", 8899)  # 本机监听端口8899
   server_socket.listen(5)
   print("等待接收")
   client_scoket,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_scoket.close()
   server_socket.close()




  老师 这里不是只有一个端口吗? 它这个错误是因为有多个端口?

Python 全系列/第三阶段:Python 网络与并发编程/网络通信 785楼
Python 全系列/第三阶段:Python 网络与并发编程/并发编程 789楼
Python 全系列/第三阶段:Python 网络与并发编程/并发编程 792楼
Python 全系列/第三阶段:Python 网络与并发编程/并发编程 794楼

from threading import Thread
from time import sleep


class MyThread(Thread):
    def __init__(self, name):
        Thread.__init__(self)
        self.name = name

    def run(self):
        print(f'Threading:{self.name} start')
        sleep(3)
        print(f'Threading:{self.name} end')


if __name__ == '__main__':
    for i in range(20):
        t = MyThread(f't{i+1}')
        t.setDaemon(True)     # 设置当前线程为守护线程,值默认为 False
        t.start()

    print('主线程结束了!!!')



老师,我还是不太理解这个程序中语句的执行顺序。

我在 if __name__ == '__main__'  这条语句前打断点,发现该程序语句执行顺序如下:


1、执行  for i in range(20)                #  i = 0
2、执行  t = MyThread(f't{i+1}')       #  t = t1

3、执行 def __init__(self, name)

4、执行 Thread.__init__(self)
5、执行 slef.name = name

6、执行  for i in range(20)                #  i = 1

......

7、循环结束,执行 print('主线程结束了!!!')


问题:

1、程序是从上往下执行的,所以首先应该是创建类对象,这个类对象代表的是类 MyThrad 的结构,里面包含实例方法 run 。然后进入程序入口,执行 for 循环里的语句,执行  t = MyThread(f't{i+1}') 语句时,会先调用 __new__() 方法创建一个实例对象,再用 __init__() 方法初始化这个实例对象,其中实例对象里也有实例属性和 run 方法。我这样理解是对的吗?


2、按照我打断点后语句的执行顺序,并没有发现执行 run 方法。请问老师,这个 run 方法是怎么调用的?什么时候调用的?



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

课程分类

百战程序员微信公众号

百战程序员微信小程序

©2014-2025百战汇智(北京)科技有限公司 All Rights Reserved 北京亦庄经济开发区科创十四街 赛蒂国际工业园
网站维护:百战汇智(北京)科技有限公司
京公网安备 11011402011233号    京ICP备18060230号-3    营业执照    经营许可证:京B2-20212637