Allow to receive a ChannelGroupFuture that will be notified once all Channels are closed.

Motivation:

It's useful to be able to be notified once all Channels that are part of the ChannelGroup are notified. This can for example be useful if you want to do a graceful shutdown.

Modifications:

- Add ChannelGroup.newCloseFuture(...) which will be notified once all Channels are notified that are part of the ChannelGroup at the time of calling.

Result:

Easier to be notified once all Channels within a ChannelGroup are closed.
This commit is contained in:
Norman Maurer 2015-06-05 12:44:55 +02:00
parent 14da966a41
commit 81d5c7c198

View File

@ -332,6 +332,36 @@ public class DefaultChannelGroup extends AbstractSet<Channel> implements Channel
return new DefaultChannelGroupFuture(this, futures, executor);
}
/**
* Returns the {@link ChannelGroupFuture} which will be notified when all {@link Channel}s that are part of this
* {@link ChannelGroup}, at the time of calling, are closed.
*/
public ChannelGroupFuture newCloseFuture() {
return newCloseFuture(ChannelMatchers.all());
}
/**
* Returns the {@link ChannelGroupFuture} which will be notified when all {@link Channel}s that are part of this
* {@link ChannelGroup}, at the time of calling, are closed.
*/
public ChannelGroupFuture newCloseFuture(ChannelMatcher matcher) {
Map<Channel, ChannelFuture> futures =
new LinkedHashMap<Channel, ChannelFuture>(size());
for (Channel c: serverChannels) {
if (matcher.matches(c)) {
futures.put(c, c.closeFuture());
}
}
for (Channel c: nonServerChannels) {
if (matcher.matches(c)) {
futures.put(c, c.closeFuture());
}
}
return new DefaultChannelGroupFuture(this, futures, executor);
}
@Override
public int hashCode() {
return System.identityHashCode(this);