Added bidirectional queues (pipes)

threads/__init__.py

 from threading import Thread, Lock, RLock
+from satella.threads.pipe import Pipe, create_pipes
 
 class BaseThread(Thread):
     """Thread with internal termination flag"""

threads/pipe.py

+import Queue
+
+class Pipe(Queue.Queue):
+    """Represents a bidirectional inter-thread queue.
+    
+    Essentially it is a Queue.Queue, so that .put elements
+    appear in the other queue.
+    
+    This will contain cyclic references, so it should be 
+    kinda persistent. 
+    
+    Call .close() to terminate that cyclic reference.
+    """
+    
+    Empty = Queue.Empty
+    
+    def __init__(self):
+        Queue.Queue.__init__(self)
+        self.other_queue = None
+        
+    def put(self, item, block=True, timeout=None):
+        Queue.Queue.put(self.other_queue, item, block, timeout)
+
+def create_pipes():
+    """Returns a pair (tuple) of Pipes connecting to each
+    other"""    
+    a = Pipe()
+    b = Pipe()
+    a.other_queue = b
+    b.other_queue = a
+    return a, b
+    
+    
\ No newline at end of file

threads/unittests/__init__.py

 from monitor import MonitorTest
-from basethread import ThreadingTest
+from basethread import ThreadingTest
\ No newline at end of file
+from pipe import PipeTest
\ No newline at end of file

threads/unittests/pipe.py

+from satella.threads import create_pipes
+from time import sleep
+
+import unittest
+
+class PipeTest(unittest.TestCase):
+
+    def test_pipe(self):
+        """Tests basic pipe predicaments"""
+
+        a, b = create_pipes()
+        
+        a.put('Lol')
+        
+        self.assertEqual(b.get(), 'Lol')
\ No newline at end of file