Package org.jboss.netty.handler.execution

Examples of org.jboss.netty.handler.execution.ExecutionHandler

38
39
40
41
42
43
44
45
46
47
48
      this.resteasyDecoder = new RestEasyHttpRequestDecoder(dispatcher.getDispatcher(), root, getProtocol(), isKeepAlive);
      this.resteasyEncoder = new RestEasyHttpResponseEncoder(dispatcher);
      this.resteasyRequestHandler = new RequestHandler(dispatcher);
      if (executorThreadCount > 0)
      {
          this.executionHandler = new ExecutionHandler(new OrderedMemoryAwareThreadPoolExecutor(executorThreadCount, 0L, 0L));
      }
      else
      {
          this.executionHandler = null;
      }
View Full Code Here
170
171
172
173
174
175
176
177
178
179
180
    super.onInit();
  }

  @Override
  protected void doStart() {
    executionHandler = new ExecutionHandler(executor);
    bootstrap = new ServerBootstrap(new NioServerSocketChannelFactory(Executors.newCachedThreadPool(),
        Executors.newCachedThreadPool()));
    bootstrap.setOption("child.tcpNoDelay", true);
    bootstrap.setPipelineFactory(new PipelineFactory());
    bootstrap.bind(new InetSocketAddress(this.port));
View Full Code Here
38
39
40
41
42
43
44
public class LocalServerPipelineFactory implements ChannelPipelineFactory {

    private final ExecutionHandler executionHandler;

    public LocalServerPipelineFactory(Executor eventExecutor) {
        executionHandler = new ExecutionHandler(eventExecutor);
    }
View Full Code Here
65
66
67
68
69
70
71
72
73
74
75
        ChannelPipeline pipeline = Channels.pipeline();
        pipeline.addLast("decoder", new TSODecoder(null));
        pipeline.addLast("encoder", new TSOEncoder());
        synchronized (this) {
            if (x == null)
                x = new ExecutionHandler(pipelineExecutor);
            if (bwhandler == null)
                bwhandler = new BandwidthMeterHandler();
            //          if (timer == null)
            //             timer = new HashedWheelTimer();
        }
View Full Code Here
323
324
325
326
327
328
329
330
331
332
333
        bootstrap = new ClientBootstrap(factory);

        int executorThreads = conf.getInt("tso.executor.threads", 3);

        bootstrap.getPipeline().addLast("executor",
                new ExecutionHandler(new OrderedMemoryAwareThreadPoolExecutor(executorThreads, 1024 * 1024, 4 * 1024 * 1024)));
        bootstrap.getPipeline().addLast("handler", this);
        bootstrap.setOption("tcpNoDelay", false);
        bootstrap.setOption("keepAlive", true);
        bootstrap.setOption("reuseAddress", true);
        bootstrap.setOption("connectTimeoutMillis", 100);
View Full Code Here
111
112
113
114
115
116
117
118
119
120
121
122
        sb.getPipeline().addLast("handler", sh);
        cb.getPipeline().addFirst("ssl", new SslHandler(cse));
        cb.getPipeline().addLast("handler", ch);

        if (isExecutorRequired()) {
            sb.getPipeline().addFirst("executor",new ExecutionHandler(eventExecutor));
            cb.getPipeline().addFirst("executor",new ExecutionHandler(eventExecutor));
        }

        Channel sc = sb.bind(new InetSocketAddress(0));
        int port = ((InetSocketAddress) sc.getLocalAddress()).getPort();
View Full Code Here
204
205
206
207
208
209
210
211
212
213
            NettyServer.cpus, NettyServer.cpus * 4, 60,
            TimeUnit.SECONDS, new LinkedBlockingQueue<Runnable>(),
            new ThreadFactoryBuilder().setNameFormat("Executor-Thread-%d")
              .setDaemon(false).setPriority(Thread.NORM_PRIORITY).build());
       
        this.executionHandler = new ExecutionHandler(executorThreadPool);
      } else {
        this.executionHandler = null;
      }
    }
View Full Code Here
560
561
562
563
564
565
566
     * Create a new {@link ExecutionHandler} which is used to execute IO-Bound handlers
     *
     * @return ehandler
     */
    protected ExecutionHandler createExecutionHander() {
        return new ExecutionHandler(new JMXEnabledOrderedMemoryAwareThreadPoolExecutor(maxExecutorThreads, 0, 0, getThreadPoolJMXPath(), "executor"));
    }
View Full Code Here
62
63
64
65
66
67
68
69
70
71
72
        // gather all chunks into a single http message
        pipeline.addLast("aggregator", new HttpChunkAggregator(maxContentLength));

        // move response handler to user worker pool
        pipeline.addLast("pipelineExecutor", new ExecutionHandler(executor));

        // response handler
        pipeline.addLast("handler", new NettyHttpResponseChannelHandler(nettyConnectionPool));

        return pipeline;
View Full Code Here
131
132
133
134
135
136
137
138
139
140
141
            isRunning.compareAndSet(true, false);
            return;
        }

        // Configure the server.
        executionHandler = new ExecutionHandler(new RequestThreadPoolExecutor());
        factory = new NioServerSocketChannelFactory(Executors.newCachedThreadPool(), Executors.newCachedThreadPool());
        ServerBootstrap bootstrap = new ServerBootstrap(factory);

        bootstrap.setOption("child.tcpNoDelay", true);
View Full Code Here
TOP

Related Classes of org.jboss.netty.handler.execution.ExecutionHandler

  • co.cask.cdap.internal.app.runtime.procedure.ProcedureProgramRunner
  • co.cask.http.NettyHttpService
  • co.paralleluniverse.galaxy.netty.TcpMessagePipelineFactory
  • co.paralleluniverse.galaxy.netty.UdpMessagePipelineFactory
  • com.alibaba.wasp.ipc.NettyServer
  • com.continuuity.http.NettyHttpService
  • com.fluxcapacitor.core.netty.NettyServer$PipelineFactory
  • com.linkedin.databus2.core.container.netty.ServerContainer
  • com.mmoscene.h4j.network.Network
  • com.netflix.recipes.rss.netty.NettyServer$PipelineFactory
    • Copyright © 2018 www.massapicom. All rights reserved.
    All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.