Java 类org.apache.thrift.server.AbstractNonblockingServer.FrameBuffer 实例源码

项目:internet_of_things_simulator    文件:Invocation.java   
public Invocation(final FrameBuffer frameBuffer) {
  this.frameBuffer = frameBuffer;
}
项目:IsoBlockProjector    文件:TIsoBlockProjectorServer.java   
public TIsoBlockProjectorServer(AbstractNonblockingServerArgs args) {
    super(args);
    requestqueue = new ConcurrentLinkedQueue<FrameBuffer>();
}
项目:IsoBlockProjector    文件:TIsoBlockProjectorServer.java   
@Override
protected boolean requestInvoke(FrameBuffer frameBuffer) {
    requestqueue.offer(frameBuffer);
    return true;
}
项目:IsoBlockProjector    文件:TIsoBlockProjectorServer.java   
/**
 * This queue of requests is to be serviced only within the main
 * minecraft server thread.  These requests may pull data out of
 * or affect change inside the minecraft world.
 */
public void serviceRequestQueue() {
    for (FrameBuffer request = requestqueue.poll();request != null;request = requestqueue.poll()) {
        request.invoke();
    }
}
项目:CadalWorkspace    文件:Invocation.java   
public Invocation(final FrameBuffer frameBuffer) {
  this.frameBuffer = frameBuffer;
}
项目:CadalWorkspace    文件:Invocation.java   
public Invocation(final FrameBuffer frameBuffer) {
  this.frameBuffer = frameBuffer;
}