pub fn new(object_store: Arc<ObjectStore>, num_worker_threads: Option<usize>) -> Self {
        let num_threads = num_worker_threads.unwrap_or_else(num_cpus::get);
        info!(%num_threads, "using specified number of threads per thread pool");

        Self {
            object_store,
            executor: Arc::new(Executor::new(num_threads)),
            job_registry: Arc::new(JobRegistry::new()),
            metric_registry: Arc::new(metrics::MetricRegistry::new()),
        }
    }
/// Creates a new `ApplicationState`
///
/// Uses number of CPUs in the system if num_worker_threads is not set
Creates a new `ApplicationState`
Uses number of CPUs in the system if num_worker_threads is not set
Creates a new ` ApplicationState ` Uses number of CPUs in the system if num_worker_threads is not set
pub fn new(object_store: Arc<ObjectStore>, num_worker_threads: Option<usize>) -> Self {
        let num_threads = num_worker_threads.unwrap_or_else(num_cpus::get);
        info!(%num_threads, "using specified number of threads per thread pool");
        Self {
            object_store,
            executor: Arc::new(Executor::new(num_threads)),
            job_registry: Arc::new(JobRegistry::new()),
            metric_registry: Arc::new(metrics::MetricRegistry::new()),
        }
    }
pub fn new ( object_store : Arc < ObjectStore > , num_worker_threads : Option < usize > ) -> Self { let num_threads = num_worker_threads . unwrap_or_else ( num_cpus :: get ) ; info ! ( num_threads " " ) ; Self { object_store , executor : Arc :: new ( Executor :: new ( num_threads ) ) , job_registry : Arc :: new ( JobRegistry :: new ( ) ) , metric_registry : Arc :: new ( metrics :: MetricRegistry :: new ( ) ) , } }
Creates a new `ApplicationState`
Uses number of CPUs in the system if num_worker_threads is not set
Creates a new ` ApplicationState ` Uses number of CPUs in the system if num_worker_threads is not set
object_store
Arc<ObjectStore>
num_worker_threads
Option<usize>
object_store
Arc<ObjectStore>
num_worker_threads
Option<usize>