Thomas Groh created BEAM-3811:
---------------------------------
Summary: Add a CancellableQueue to make close methods safer
Key: BEAM-3811
URL: https://issues.apache.org/jira/browse/BEAM-3811
Project: Beam
Issue Type: Bug
Components: runner-core
Reporter: Thomas Groh
There are multiple locations in which, on a call to {{close}} within some
portability service, we wish to close all of our outstanding clients. However,
the call to {{close}} can be interleaved with calls to the method which creates
a new client. Without having an explicit thread-safe signal from the collection
of pending clients, there's no way to ensure that all of the clients for a
service are closed when that service is closed.
As a result, some clients are only terminated by the forceful termination of
the server, killing the connection.
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)
