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

老师,我的电脑配置是8核16线程的,我把进程池设置为17个,每个进程sleep(2),视频老师说进程池里的数量不能随便写,最多就是自己电脑的cpu数,我这明显超过电脑cpu了,但是感觉17个进程是同时完成的。

from multiprocessing import Pool, Process
from time import sleep


def func1(name):
    a=0
    print(f"进程{name}的工作")
    for i in range(1000000):
        a+=i
    print(a)
    sleep(2)


if __name__ == '__main__':
    pool = Pool(17)
    pool.apply_async(func=func1, args=("xue1",))
    pool.apply_async(func=func1, args=("xue2",))
    pool.apply_async(func=func1, args=("xue3",))
    pool.apply_async(func=func1, args=("xue4",))
    pool.apply_async(func=func1, args=("xue5",))
    pool.apply_async(func=func1, args=("xue6",))
    pool.apply_async(func=func1, args=("xue7",))
    pool.apply_async(func=func1, args=("xue8",))
    pool.apply_async(func=func1, args=("xue9",))
    pool.apply_async(func=func1, args=("xue10",))
    pool.apply_async(func=func1, args=("xue11",))
    pool.apply_async(func=func1, args=("xue12",))
    pool.apply_async(func=func1, args=("xue13",))
    pool.apply_async(func=func1, args=("xue14",))
    pool.apply_async(func=func1, args=("xue15",))
    pool.apply_async(func=func1, args=("xue16",))
    pool.apply_async(func=func1, args=("xue17",))
    pool.close()
    pool.join()


Python 全系列/第三阶段:Python 网络与并发编程/并发编程 307楼
Python 全系列/第三阶段:Python 网络与并发编程/并发编程 310楼
Python 全系列/第三阶段:Python 网络与并发编程/并发编程 311楼
Python 全系列/第三阶段:Python 网络与并发编程/网络通信 313楼

老师,请问为什么我i这里文件不存在啊,我的图片是放在桌面上的

# tftp下载器
from socket import *
import struct     # 帮助组织数据
filename = 'siyue.jpg'    # 存放要下载的文件名
server_ip = '10.174.149.195'  # 存放服务器所在的IP地址
send_data = struct.pack('!H%dsb5sb' % len(filename), 1, filename.encode(), 0, 'octet'.encode(), 0)
s = socket(AF_INET, SOCK_DGRAM)    # 创建套接字对象
s.sendto(send_data, (server_ip, 69))  # 第一次发送,链接服务器69端口
f = open(filename, 'ab')   # 创建一个空文件,名字与我们要下载的文件同名,a:以追加模式打开(必要时可以创建)append;b:表示二进制
while True:
    recv_data = s.recvfrom(1024)  # 接收数据
    caozuoma, ask_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[0])))
    f.write(recv_data[0][4:])   # 将数据写入
    if len(recv_data[0]) < 516:
        break
    ack_data = struct.pack("!HH", 4, ack_num)
                          # 操作码和快编号分别占用两个空间
    s.sendto(ack_data, (server_ip, rand_port))   # 回复ACK确认包

image.png

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

课程分类

百战程序员微信公众号

百战程序员微信小程序

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