Method try_submit

src/server/worker_pool.rs:96–123

Try to submit a job without waiting for a worker to become available Returns None if no workers are available, otherwise returns a JobHandle.

(&self, job: T)

    ///
    /// Returns None if no workers are available, otherwise returns a JobHandle.
    pub async fn try_submit(&self, job: T) -> Result<Option<JobHandle>, JobError> {
        // Check if we're shutting down
        if *self.shutting_down.lock().await {
            return Err(JobError::from("Worker pool is shutting down".to_string()));
        }

        // Try to acquire a permit without waiting
        let permit = match self.semaphore.clone().try_acquire_owned() {
            Ok(permit) => permit,
            Err(_) => return Ok(None),
        };

        // Get the job ID before moving the job
        let job_id = job.job_id();

        // Add the job to the active jobs set for tracking
        let mut jobs = self.active_jobs.lock().await;
        jobs.spawn(async move {
            // Hold the permit for the duration of the job
            let _permit = permit;

            // Execute the job
            job.execute().await
        });
        drop(jobs);

        Ok(Some(JobHandle { job_id }))
    }

    /// Clean up completed jobs from the internal tracking
    ///