Managing keyboard interrupts with multi-threaded parallel queues

[dineshbvadhia]

Using the test example:

def multi_threaded_parallel(self):
        """Create consumer and producer threads"""

        m_queue = self.queue_class(
            path=self.path, multithreading=True, auto_commit=self.auto_commit)

        def producer():
            for i in range(1000): m_queue.put('var%d' % i)

        def consumer():
            for i in range(1000)  x = m_queue.get(block=True)

        c = Thread(target=consumer)
        c.start()
        p = Thread(target=producer)
        p.start()
        
        p.join()
        c.join()

a. Are there 3 threads - the calling thread, and the p and c threads?
b. If there is a keyboard interrupt while the p and c threads are working, I want to pass control back to the calling thread to handle the exception safetly. How would this be achieved?