| 51 | return True |
| 52 | |
| 53 | class UDPFibServer(UDPServer): |
| 54 | def handle_receive(self): |
| 55 | msg, addr = self.sock.recvfrom(128) |
| 56 | n = int(msg) |
| 57 | pool.run(fib, (n,), callback=lambda r: self.respond(r, addr)) |
| 58 | |
| 59 | def respond(self, result, addr): |
| 60 | self.sock.sendto(str(result).encode('ascii'), addr) |
| 61 | |
| 62 | if __name__ == '__main__': |
| 63 | pool = ThreadPoolHandler(16) |