anchor.diff:            '            self.print_queue.put(message)'
             ''
             '        def process_print_queue(self):'
  -          '            import time'
             '            while True:'
  -          '                time.sleep(0.2)'
  +          '                self._sleep(0.2)'
             '                l = [self.print_queue.get()]'
             '                while not self.print_queue.empty():'
             '                    l.append(self.print_queue.get())'
  
positive.code:           '        softspace=0'
            '        encoding=None'
            '        def __init__(self, stream):'
            '            self._stream = stream'
            '            self.writing = False'
            '            import Queue'
            '            self.print_queue = Queue.Queue()'
            ''
            '            import threading'
            
  
negative.code:           '                with dbg_manager.user_lock:'
            '                    conn.poll_all(0.01)'
            '                if thread_id != dbg_manager.active_thread:'
            '                    dbg_manager._sleep(0.1)'
            ''
            '            if dbg_manager.debug_command == dbg_manager.dcRun:'
            '                self.set_continue()'
  