third-party/atomix/utils/src/main/java/io/atomix/utils/concurrent/ThreadModel.java

   1 /*
   2  * Copyright 2017-present Open Networking Foundation
   3  *
   4  * Licensed under the Apache License, Version 2.0 (the "License");
   5  * you may not use this file except in compliance with the License.
   6  * You may obtain a copy of the License at
   7  *
   8  * http://www.apache.org/licenses/LICENSE-2.0
   9  *
  10  * Unless required by applicable law or agreed to in writing, software
  11  * distributed under the License is distributed on an "AS IS" BASIS,
  12  * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
  13  * See the License for the specific language governing permissions and
  14  * limitations under the License.
  15  */
  16 package io.atomix.utils.concurrent;
  17
  18 import org.slf4j.Logger;
  19
  20 /**
  21  * Raft thread model.
  22  */
  23 public enum ThreadModel {
  24
  25   /**
  26    * A thread model that creates a thread pool to be shared by all services.
  27    */
  28   SHARED_THREAD_POOL {
  29     @Override
  30     public ThreadContextFactory factory(String nameFormat, int threadPoolSize, Logger logger) {
  31       return new BlockingAwareThreadPoolContextFactory(nameFormat, threadPoolSize, logger);
  32     }
  33   },
  34
  35   /**
  36    * A thread model that creates a thread for each Raft service.
  37    */
  38   THREAD_PER_SERVICE {
  39     @Override
  40     public ThreadContextFactory factory(String nameFormat, int threadPoolSize, Logger logger) {
  41       return new BlockingAwareSingleThreadContextFactory(nameFormat, threadPoolSize, logger);
  42     }
  43   };
  44
  45   /**
  46    * Returns a thread context factory.
  47    *
  48    * @param nameFormat the thread name format
  49    * @param threadPoolSize the thread pool size
  50    * @param logger the thread logger
  51    * @return the thread context factory
  52    */
  53   public abstract ThreadContextFactory factory(String nameFormat, int threadPoolSize, Logger logger);
  54 }