GUI+多线程+socket+队列，怎么搞，入队阻塞！😂

看了这篇关于 GUI 情景中的 socket 编程的文章 http://www.jianshu.com/p/731a8359c2c5

然后仿照着按照自己的业务逻辑去做，出现了以下的问题。

现在有两个线程一个队列，一个线程负责入队，一个负责出队。 每个线程都是 1s 进行一次操作。 但是负责入队的线程经常会阻塞，就像阻塞了几秒，一下子入队好几次。

以下的代码都是关于队列cmd_q的
入队相关的代码

def send_heartbeat(self, receive_dic=None):
    # 转换为连接状态
    self.api_manager.socket_is_connect = True

    # 开始发送心跳
    self.heartbeat_thread = threading.Thread(target=self.__send_heartbeat_timer)
    self.heartbeat_thread.start()


def __send_heartbeat_timer(self):
    while self.api_manager.socket_is_connect:
        print("%s !!!!!!!!!!!!!put command  start!!!!!" % time.asctime(time.localtime(time.time())))
        self.api_manager.client.cmd_q.put(ClientCommand(ClientCommand.SEND, "heartbeat"))
        print("%s !!!!!!!!!!!!!put command  end!!!!!" % time.asctime(time.localtime(time.time())))
        logging.info("time: %s   send bearheart", time.asctime(time.localtime(time.time())))
        time.sleep(4) 

出队相关的代码

def run(self):
    while self.alive.isSet():
        try:
            # Queue.get with timeout to allow checking self.alive
            # print("%s !!!!!!!!!!!!!get command!!!!!" % time.asctime(time.localtime(time.time())))

            print("%s !!!!!!!!!!!!!get command  start!!!!!" % time.asctime(time.localtime(time.time())))
            cmd = self.cmd_q.get(True, 1)
            if (cmd.data == "heartbeat"):
                print("%s !!!!!!!!!!!!!get command  end!!!!!" % time.asctime(time.localtime(time.time())))
            handler = self.handlers[cmd.type]
            handler(cmd)
        except queue.Empty as e:
            continue