andreacavalli/netty5
1
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

'break' statement in a 'finally' block!?

Browse Source
This commit is contained in:
Trustin Lee 2012-11-12 09:55:07 +09:00
parent 849a265c2e
commit a3acde0b73
1 changed files with 8 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
src/main/java/org/jboss/netty/channel/socket/oio/AbstractOioWorker.java
View File

@ -15,17 +15,17 @@
*/ */
package org.jboss.netty.channel.socket.oio; package org.jboss.netty.channel.socket.oio;
import static org.jboss.netty.channel.Channels.*; import org.jboss.netty.channel.Channel;
import org.jboss.netty.channel.ChannelFuture;
import org.jboss.netty.channel.Channels;
import org.jboss.netty.channel.socket.Worker;
import java.io.IOException; import java.io.IOException;
import java.net.SocketTimeoutException; import java.net.SocketTimeoutException;
import java.util.Queue; import java.util.Queue;
import java.util.concurrent.ConcurrentLinkedQueue; import java.util.concurrent.ConcurrentLinkedQueue;
import org.jboss.netty.channel.Channel; import static org.jboss.netty.channel.Channels.*;
import org.jboss.netty.channel.ChannelFuture;
import org.jboss.netty.channel.Channels;
import org.jboss.netty.channel.socket.Worker;
/** /**
* Abstract base class for Oio-Worker implementations * Abstract base class for Oio-Worker implementations
@ -85,12 +85,12 @@ abstract class AbstractOioWorker<C extends AbstractOioChannel> implements Worker
} }
} finally { } finally {
processEventQueue(); processEventQueue();
}
if (!cont) { if (!cont) {
break; break;
} }
} }
}
// Setting the workerThread to null will prevent any channel // Setting the workerThread to null will prevent any channel
// operations from interrupting this thread from now on. // operations from interrupting this thread from now on.