diff options
| author |  kpayson64 <kpayson@google.com> | 2018-04-30 09:06:31 -0700 |
|---|---|---|
| committer | kpayson64 <kpayson@google.com> | 2018-04-30 14:03:47 -0700 |
| commit | a0bc0ac169ecae34b5a7a43cb5e0fdfc9662d22a (patch) | |
| tree | 607a907a9c87f2661fd871bca3328c6e85756ff2 /src/python/grpcio/grpc/beta | |
| parent | 6dcb2f73338392f9a197671fa56254eb2197a1ca (diff) | |
Remove CleanupThread
This is no longer needed with the addition of a close() API that allows
clean shutdown.
Diffstat (limited to 'src/python/grpcio/grpc/beta')
| -rw-r--r-- | src/python/grpcio/grpc/beta/_server_adaptations.py | 7 |
1 files changed, 2 insertions, 5 deletions
diff --git a/src/python/grpcio/grpc/beta/_server_adaptations.py b/src/python/grpcio/grpc/beta/_server_adaptations.py index 3c04fd7639..ccafec8951 100644 --- a/src/python/grpcio/grpc/beta/_server_adaptations.py +++ b/src/python/grpcio/grpc/beta/_server_adaptations.py @@ -168,11 +168,8 @@ def _run_request_pipe_thread(request_iterator, request_consumer, return request_consumer.terminate() - def stop_request_pipe(timeout): # pylint: disable=unused-argument - thread_joined.set() - - request_pipe_thread = _common.CleanupThread( - stop_request_pipe, target=pipe_requests) + request_pipe_thread = threading.Thread(target=pipe_requests) + request_pipe_thread.daemon = True request_pipe_thread.start() |