查看本类的 API文档回源码主页

   /*
    * Copyright 2012 The Netty Project
    *
    * The Netty Project licenses this file to you under the Apache License,
    * version 2.0 (the "License"); you may not use this file except in compliance
    * with the License. You may obtain a copy of the License at:
    *
    *   http://www.apache.org/licenses/LICENSE-2.0
    *
   * Unless required by applicable law or agreed to in writing, software
   * distributed under the License is distributed on an "AS IS" BASIS, WITHOUT
   * WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the
   * License for the specific language governing permissions and limitations
   * under the License.
   */
  package org.jboss.netty.handler.execution;
  
  import java.util.concurrent.Executor;
  
  import org.jboss.netty.channel.ChannelEvent;
  import org.jboss.netty.channel.ChannelHandlerContext;
  import org.jboss.netty.util.EstimatableObjectWrapper;
  
  public abstract class ChannelEventRunnable implements Runnable, EstimatableObjectWrapper {
  
      /**
       * An <em>internal use only</em> thread-local variable that tells the
       * {@link Executor} that this worker acquired a worker thread from.
       */
      protected static final ThreadLocal<Executor> PARENT = new ThreadLocal<Executor>();
  
      protected final ChannelHandlerContext ctx;
      protected final ChannelEvent e;
      int estimatedSize;
      private final Executor executor;
  
      /**
       * Creates a {@link Runnable} which sends the specified {@link ChannelEvent}
       * upstream via the specified {@link ChannelHandlerContext}.
       */
      protected ChannelEventRunnable(ChannelHandlerContext ctx, ChannelEvent e, Executor executor) {
          this.ctx = ctx;
          this.e = e;
          this.executor = executor;
      }
  
      /**
       * Returns the {@link ChannelHandlerContext} which will be used to
       * send the {@link ChannelEvent} upstream.
       */
      public ChannelHandlerContext getContext() {
          return ctx;
      }
  
      /**
       * Returns the {@link ChannelEvent} which will be sent upstream.
       */
      public ChannelEvent getEvent() {
          return e;
      }
  
      public Object unwrap() {
          return e;
      }
  
      public final void run() {
          doRun();
      }
  
      protected abstract void doRun();
  }