No need to use a concurrent Queue with out new thread-model. See #626
This commit is contained in:
parent
09d9f46e58
commit
7eef61580e
@ -15,8 +15,8 @@
|
|||||||
*/
|
*/
|
||||||
package io.netty.handler.codec.spdy;
|
package io.netty.handler.codec.spdy;
|
||||||
|
|
||||||
|
import java.util.LinkedList;
|
||||||
import java.util.Queue;
|
import java.util.Queue;
|
||||||
import java.util.concurrent.ConcurrentLinkedQueue;
|
|
||||||
|
|
||||||
import io.netty.channel.ChannelHandlerContext;
|
import io.netty.channel.ChannelHandlerContext;
|
||||||
import io.netty.handler.codec.MessageToMessageCodec;
|
import io.netty.handler.codec.MessageToMessageCodec;
|
||||||
@ -31,7 +31,7 @@ import io.netty.handler.codec.http.HttpResponse;
|
|||||||
public class SpdyHttpResponseStreamIdHandler extends
|
public class SpdyHttpResponseStreamIdHandler extends
|
||||||
MessageToMessageCodec<HttpRequest, HttpRequest, HttpResponse, HttpResponse> {
|
MessageToMessageCodec<HttpRequest, HttpRequest, HttpResponse, HttpResponse> {
|
||||||
private static final Integer NO_ID = -1;
|
private static final Integer NO_ID = -1;
|
||||||
private final Queue<Integer> ids = new ConcurrentLinkedQueue<Integer>();
|
private final Queue<Integer> ids = new LinkedList<Integer>();
|
||||||
|
|
||||||
public SpdyHttpResponseStreamIdHandler() {
|
public SpdyHttpResponseStreamIdHandler() {
|
||||||
super(new Class<?>[] { HttpRequest.class }, new Class<?>[] { HttpResponse.class });
|
super(new Class<?>[] { HttpRequest.class }, new Class<?>[] { HttpResponse.class });
|
||||||
|
Loading…
Reference in New Issue
Block a user