java_concurrency5.java

class RequestRunnerExecutor
{
    private final Set<HttpWebResponse> runningRequests = new HashSet<>();
    
    public ListenableFuture<Boolean> runRequest( URI uri )
    {
        final Future<HttpWebResponse> futureResponse = httpClient.execute(
			HttpAsyncMethods.createGet( uri ),
			new ByteConsumer(),
			new ResponseCallback()
	);
        
        runningRequests.add( futureResponse );
        
        result.addListener( new Runnable()
	{
		@Override
		public void run()
		{
			runningRequests.remove( futureResponse );
		}
	} );
		
	return result;
    }
}
    




//////////////////////////////////////////////////////////





class RequestRunnerExecutor
{
    private final Set<HttpWebResponse> runningRequests = Sets.newConcurrentHashSet();
    
    public ListenableFuture<Boolean> runRequest( URI uri )
    {
        final Future<HttpWebResponse> futureResponse = httpClient.execute(
			HttpAsyncMethods.createGet( uri ),
			new ByteConsumer(),
			new ResponseCallback()
	);
        
        runningRequests.add( futureResponse );
        
        result.addListener( new Runnable()
	{
		@Override
		public void run()
		{
			runningRequests.remove( futureResponse );
		}
	} );
		
	return result;
    }
}
    




//////////////////////////////////////////////////////////





class RequestRunnerExecutor
{
    private final Set<HttpWebResponse> runningRequests = newSetFromMap( new ConcurrentHashMap<>() );
    
    public ListenableFuture<Boolean> runRequest( URI uri )
    {
        final Future<HttpWebResponse> futureResponse = httpClient.execute(
			HttpAsyncMethods.createGet( uri ),
			new ByteConsumer(),
			new ResponseCallback()
	);
        
        runningRequests.add( futureResponse );
        
        result.addListener( new Runnable()
	{
		@Override
		public void run()
		{
			runningRequests.remove( futureResponse );
		}
	} );
		
	return result;
    }
}