Package org.apache.cassandra.concurrent

Examples of org.apache.cassandra.concurrent.NamedThreadFactory

281
282
283
284
285
286
287
288
            ExecutorService executorService = new ThreadPoolExecutor(serverArgs.minWorkerThreads,
                                                                     serverArgs.maxWorkerThreads,
                                                                     60,
                                                                     TimeUnit.SECONDS,
                                                                     new SynchronousQueue<Runnable>(),
                                                                     new NamedThreadFactory("Thrift"));
            return new CustomTThreadPoolServer(serverArgs, executorService);
        }
View Full Code Here
1229
1230
1231
1232
1233
1234
1235
    private static class CompactionExecutor extends JMXEnabledThreadPoolExecutor
    {
        protected CompactionExecutor(int minThreads, int maxThreads, String name, BlockingQueue<Runnable> queue)
        {
            super(minThreads, maxThreads, 60, TimeUnit.SECONDS, queue, new NamedThreadFactory(name, Thread.MIN_PRIORITY), "internal");
        }
View Full Code Here
86
87
88
89
90
91
92
93
94
95
96
            ThreadPoolExecutor invoker = new JMXEnabledThreadPoolExecutor(DatabaseDescriptor.getRpcMinThreads(),
                                                                          DatabaseDescriptor.getRpcMaxThreads(),
                                                                          60L,
                                                                          TimeUnit.SECONDS,
                                                                          new SynchronousQueue<Runnable>(),
                                                                          new NamedThreadFactory("RPC-Thread"), "RPC-THREAD-POOL");

            com.thinkaurelius.thrift.util.TBinaryProtocol.Factory protocolFactory = new com.thinkaurelius.thrift.util.TBinaryProtocol.Factory(true, true);

            TDisruptorServer.Args serverArgs = new TDisruptorServer.Args(serverTransport).useHeapBasedAllocation(true)
                                                                                         .inputTransportFactory(args.inTransportFactory)
View Full Code Here
46
47
48
49
50
51
52
53
54
55
56
        if (args.length >= 1) {
            NUM_THREADS = Integer.parseInt(args[0]);
            System.out.println("Setting num threads to: " + NUM_THREADS);
        }
        ExecutorService executor = new JMXEnabledThreadPoolExecutor(NUM_THREADS, NUM_THREADS, 60,
                TimeUnit.SECONDS, new ArrayBlockingQueue<Runnable>(10 * NUM_THREADS), new NamedThreadFactory(""), "");
        ScheduledExecutorService scheduled = Executors.newScheduledThreadPool(1);

        org.apache.cassandra.SchemaLoader.loadSchema();
        org.apache.cassandra.SchemaLoader.schemaDefinition(""); // leave def. blank to maintain old behaviour
        final AtomicLong count = new AtomicLong();
View Full Code Here
885
886
887
888
889
890
891
892
        private volatile long totalBytesCompacted = 0L;
        private volatile long totalCompactionsCompleted = 0L;

        protected CompactionExecutor(int minThreads, int maxThreads, String name, BlockingQueue<Runnable> queue)
        {
            super(minThreads, maxThreads, 60, TimeUnit.SECONDS, queue, new NamedThreadFactory(name, Thread.MIN_PRIORITY));
            allowCoreThreadTimeOut(true);
        }
View Full Code Here
792
793
794
795
796
797
798
799
    private static class CompactionExecutor extends ThreadPoolExecutor
    {
        protected CompactionExecutor(int minThreads, int maxThreads, String name, BlockingQueue<Runnable> queue)
        {
            super(minThreads, maxThreads, 60, TimeUnit.SECONDS, queue, new NamedThreadFactory(name, Thread.MIN_PRIORITY));
            allowCoreThreadTimeOut(true);
        }
View Full Code Here
273
274
275
276
277
278
279
280
            ExecutorService executorService = new ThreadPoolExecutor(serverArgs.minWorkerThreads,
                                                                     serverArgs.maxWorkerThreads,
                                                                     60,
                                                                     TimeUnit.SECONDS,
                                                                     new SynchronousQueue<Runnable>(),
                                                                     new NamedThreadFactory("Thrift"));
            return new CustomTThreadPoolServer(serverArgs, executorService);
        }
View Full Code Here
32
33
34
35
36
37
38
    {
        super(DatabaseDescriptor.getNativeTransportMinThreads(),
              DatabaseDescriptor.getNativeTransportMaxThreads(),
              CORE_THREAD_TIMEOUT_SEC, TimeUnit.SECONDS,
              new LinkedBlockingQueue<Runnable>(32), // Seems to help smooth latency compared to SynchronousQueue.
              new NamedThreadFactory("Native-Transport-Requests"));
    }
View Full Code Here
946
947
948
949
950
951
952
953
    private static class CompactionExecutor extends ThreadPoolExecutor
    {

        protected CompactionExecutor(int minThreads, int maxThreads, String name, BlockingQueue<Runnable> queue)
        {
            super(minThreads, maxThreads, 60, TimeUnit.SECONDS, queue, new NamedThreadFactory(name, Thread.MIN_PRIORITY));
            allowCoreThreadTimeOut(true);
        }
View Full Code Here
42
43
44
45
46
47
48
49
        super(DatabaseDescriptor.getNativeTransportMaxThreads(),
              0, // We don't use the per-channel limit, only the global one
              MAX_QUEUED_REQUESTS,
              CORE_THREAD_TIMEOUT_SEC, TimeUnit.SECONDS,
              sizeEstimator(),
              new NamedThreadFactory(THREAD_FACTORY_ID));
        metrics = new ThreadPoolMetrics(this, "transport", THREAD_FACTORY_ID);
    }
View Full Code Here
TOP

Related Classes of org.apache.cassandra.concurrent.NamedThreadFactory

  • org.apache.cassandra.db.commitlog.ComitLogStress
  • org.apache.cassandra.db.compaction.CompactionManager$CompactionExecutor
  • org.apache.cassandra.db.compaction.ParallelCompactionIterable$Reducer
  • org.apache.cassandra.db.CompactionManager$CompactionExecutor
  • org.apache.cassandra.net.MessagingService
  • org.apache.cassandra.service.AbstractCassandraDaemon$CleaningThreadPool
  • org.apache.cassandra.thrift.CassandraDaemon$ThriftServer
  • org.apache.cassandra.thrift.CustomTHsHaServer$Factory
  • org.apache.cassandra.thrift.CustomTThreadPoolServer$Factory
  • org.apache.cassandra.thrift.ThriftServer$CleaningThreadPool
    • 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.