Pykka graceful termination

[ghost]

I have a pool of threads like this example:

https://github.com/jodal/pykka/blob/develop/examples/resolver.py

I want to catch a keyboard error to permit the user to gracefully shutdown the program with
ctrl-c

the problem is that I get an error like this

Traceback (most recent call last):
  File "/itel/itelstreamcheck/itelstreamcheck/audio/player.py", line 338, in <module>
    _run(3, *bad_uri)
  File "/itel/itelstreamcheck/itelstreamcheck/audio/player.py", line 309, in _run
    uri_checked = zip(uris, pykka.get_all(scan_result))
  File "/usr/lib/python2.7/site-packages/pykka/future.py", line 273, in get_all
DEBUG 2016-08-25 09:59:21,733 [(player.py:203)][1913:Player-4] __main__      Player Player (urn:uuid:77c7402c-c565-4965-ac85-4c0e3a6ff161) check http://icestreaming.rai.it/1.mp3  
return [future.get(timeout=timeout) for future in futures]
  File "/usr/lib/python2.7/site-packages/pykka/threading.py", line 50, in get
    self._data = self._queue.get(True, timeout)
  File "/usr/lib/python2.7/Queue.py", line 168, in get
    self.not_empty.wait()
  File "/usr/lib/python2.7/threading.py", line 340, in wait
    waiter.acquire()
KeyboardInterrupt

because I interrupt the process and the queue created by future is not empty

how I can gently shutdown pykka actors and queue with an exception???

my main look like this (i have a pair of extra thread)

def _run(pool_size, *uris):
    global timer
    import pprint
    import sys

# signal.signal(signal.SIGINT, sigterm_handler)
# signal.signal(signal.SIGTERM, sigterm_handler)

loop = gobject.MainLoop()

logger.info('Start watchdog')
watchdog = Watchdog().start()
w_proxy = watchdog.proxy()

logger.info('Start resolvers')
resolvers = [Player.start().proxy() for _ in range(pool_size)]

timer.start()

logger.info('Distribute work by mapping IPs to resolvers (not blocking)')
scan_result = []

for i, uri in enumerate(uris):
    scan_result.append(resolvers[i % len(resolvers)].check_uri(uri))

logger.info('Gather results (blocking)')
uri_checked = zip(uris, pykka.get_all(scan_result))
pprint.pprint(list(uri_checked))

# logger.info('Clean up')
try:
    loop.run()
except KeyboardInterrupt:
    logger.info('Stopping program from Mainloop')
    loop.quit()
    timer.stop()

    try:
        if scan_result:
            for i in scan_result:
                i.join(timeout=250)
    except:
        pass

    pykka.ActorRegistry.stop_all()
    thread.interrupt_main()          # or is better sys.exit(0)

    # for act in pykka.ActorRegistry().get_all():
    #     act.stop(block=True)

    # threading
    # sys.exit(0)