From 8e23fc73a5582d9a9b8ff2fcf12da2165650f295 Mon Sep 17 00:00:00 2001 From: Sean Arietta Date: Sat, 31 Jan 2015 21:54:04 -0800 Subject: [PATCH] Switched from multiprocessing to thread --- socketIO_client/__init__.py | 7 ++++--- 1 file changed, 4 insertions(+), 3 deletions(-) diff --git a/socketIO_client/__init__.py b/socketIO_client/__init__.py index 8188bec..3a8ecee 100644 --- a/socketIO_client/__init__.py +++ b/socketIO_client/__init__.py @@ -2,10 +2,10 @@ from collections import namedtuple import copy import logging import json -import multiprocessing import parser from parser import Message, Packet, MessageType, PacketType import requests +import threading import time try: @@ -479,10 +479,11 @@ class SocketIO(object): self._terminate_heartbeat(); _log.debug("[start heartbeat pacemaker]"); - self.heartbeat_terminator = multiprocessing.Event(); - self.heartbeat_thread = multiprocessing.Process( + self.heartbeat_terminator = threading.Event(); + self.heartbeat_thread = threading.Thread( target = _make_heartbeat_pacemaker, args = (self.heartbeat_terminator, transport, self.session.heartbeat_interval / 2)); + self.heartbeat_thread.daemon = True; self.heartbeat_thread.start(); def _get_transport(self):