V2EX = way to explore
V2EX 是一个关于分享和探索的地方
现在注册
已注册用户请  登录
gino86
V2EX  ›  程序员

Python 开一个新的线程接收 socket 数据出错

  •  
  •   gino86 · 2017-01-17 15:42:22 +08:00 · 3324 次点击
    这是一个创建于 2858 天前的主题,其中的信息可能已经有所发展或是发生改变。

    开发环境 windows ,在新的线程中处理数据接收报错: OSError: [WinError 10038] 在一个非套接字上尝试了一个操作。错在__execute__中的 self.request.recv(8192),不使用线程的话没有问题。请教大家问题在哪了

    @log("任务已准备开始。。。")
        def start(self):
            if not self.status["started"] and \
                    not self.status["finished"]:
                self.status["started"] = True
                t = threading.Thread(None, self.__execute__)
                t.start()
            else:
                raise TaskAlreadyStartedError("任务已经开启,不能重复开启相同的任务。。。")
                
    @log("正在执行写入任务...")
        def __execute__(self):
            filename = self.fileInfo.get_name()
            full_path = self.backupDirectory + "/" + filename
            total_len = 0
            with open(full_path, 'wb') as file:
                while True:
                    try:
                        data = self.request.recv(8192)
                        if not data:
                            break
                        file.write(data)
                        total_len += len(data)
                        self.currentProgress = total_len
                        self.report_progress()
                    except Exception as error:
                        if total_len != self.fileInfo.get_size():  # 客户端提前关闭
                            self.status["finished"] = False
                            self.status["stopped"] = True
                            if self.auto_rollback:
                                file.close()  # 释放当前文件句柄,否则造成文件无法回滚
                                try:
                                    self.rollback()
                                except Exception as rollbackerror:
                                    logging.error(str(rollbackerror))
                        logging.error(str(error))
                        break
    
            if total_len == self.fileInfo.get_size():
                self.status["finished"] = True
                self.status["stopped"] = True
                print("任务%s 已经把文件%s 保存到%s" % (str(self.taskId), filename, self.backupDirectory))
    
    4 条回复    2017-01-18 08:25:45 +08:00
    kaneg
        1
    kaneg  
       2017-01-17 16:54:57 +08:00   ❤️ 1
    你只贴了部分代码, 我推测你在执行 start()之后紧接着 close 了 socket 。在非线程模式下, execute 执行完之后才 close 的,所以没问题。而在线程模式下,刚启动线程, socket 就被 close 了,所以就抛了那个错误
    gino86
        2
    gino86  
    OP
       2017-01-17 17:31:43 +08:00
    @kaneg 我竟然没有发现这么低级的错误, join 一下,然后就好了。
    gino86
        3
    gino86  
    OP
       2017-01-17 17:34:11 +08:00
    @kaneg 因为是基于 python 的 ThreadingTCPServer 开发的,一般情况下不需要显式关闭 socket ,所以没有注意到这个问题
    AlisaDestiny
        4
    AlisaDestiny  
       2017-01-18 08:25:45 +08:00 via iPhone
    @kaneg 666 。不看代码而答出错误所在。我服。
    关于   ·   帮助文档   ·   博客   ·   API   ·   FAQ   ·   实用小工具   ·   3639 人在线   最高记录 6679   ·     Select Language
    创意工作者们的社区
    World is powered by solitude
    VERSION: 3.9.8.5 · 36ms · UTC 04:34 · PVG 12:34 · LAX 20:34 · JFK 23:34
    Developed with CodeLauncher
    ♥ Do have faith in what you're doing.