
开发环境 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)) 1 kaneg 2017-01-17 16:54:57 +08:00 你只贴了部分代码, 我推测你在执行 start()之后紧接着 close 了 socket 。在非线程模式下, execute 执行完之后才 close 的,所以没问题。而在线程模式下,刚启动线程, socket 就被 close 了,所以就抛了那个错误 |
3 gino86 OP @kaneg 因为是基于 python 的 ThreadingTCPServer 开发的,一般情况下不需要显式关闭 socket ,所以没有注意到这个问题 |
4 AlisaDestiny 2017-01-18 08:25:45 +08:00 via iPhone @kaneg 666 。不看代码而答出错误所在。我服。 |