thread test

1 files changed, 10 insertions, 4 deletions

diff --git a/python/examples/futureHouse/futureHouse.py b/python/examples/futureHouse/futureHouse.py
index 2978c24..c179347 100644
--- a/python/examples/futureHouse/futureHouse.py
+++ b/python/examples/futureHouse/futureHouse.py
@@ -113,8 +113,14 @@ def reconnect(message):
 def disconnect(message):
     print("DISCONNECTED")
 
-pubnub.subscribe(channel, callback=callback, error=callback,
-                 connect=connect, reconnect=reconnect, disconnect=disconnect)
+def pnSubscribe(x):
+    pubnub.subscribe(channel, callback=callback, error=callback,
+                     connect=connect, reconnect=reconnect, disconnect=disconnect)
+
+try:
+    thread.start_new_thread( pnSubscribe, (0,) )
+except:
+    print "Error: unable to start Subscribe thread"
 
 # http://www.raspberrypi.org/forums/viewtopic.php?f=37&t=32826
 
@@ -199,9 +205,9 @@ def startCycling():
             # print str(x) + ": " + str(leds[x]['minPulseLength']) + " " + str(leds[x]['maxPulseLength']) + " " + str(leds[x]['waitFloor']) + " " + str(leds[x]['waitCeiling'])
             # Change speed of continuous servo on channel O
             try:
-                t = thread.start_new_thread( cycleLEDs, (x,) )
+                thread.start_new_thread( cycleLEDs, (x,) )
             except:
-                print "Error: unable to start thread"
+                print "Error: unable to start LED thread"
 
 
             #cycleLEDs(x)