return false;
        } else {
          long now = System.nanoTime();
          NANOSECONDS.timedWait(lock, nanos);
          nanos -= System.nanoTime() - now; // subtract the actual time we waited
        }
      }
    }
  }

  /**
   * Checks if the executor has been shut down and increments the running task count.
   *

    waiter2.join();
  }

  public void testRemoveWaiter_polling() throws Exception {
    AbstractFuture<String> future = new AbstractFuture<String>() {};
    WaiterThread waiter = new WaiterThread(future);
    waiter.start();
    waiter.awaitWaiting();
    PollingThread poller = new PollingThread(future);
    poller.start();
    PollingThread poller2 = new PollingThread(future);
    poller2.start();

    waiter2.join();
  }

  public void testRemoveWaiter_polling() throws Exception {
    AbstractFuture<String> future = new AbstractFuture<String>() {};
    WaiterThread waiter = new WaiterThread(future);
    waiter.start();
    waiter.awaitWaiting();
    PollingThread poller = new PollingThread(future);
    poller.start();
    PollingThread poller2 = new PollingThread(future);
    poller2.start();

            if (logger.isDebugEnabled()) {
                logger.debug("Script raised JobProcessingException", e);
            }
            throw e;
        } catch (final Exception e) {
            // Log and return null for other exceptions to maintain backward compatibility
            logger.warn("Failed to evaluate Groovy script: template={}, parameters={}", template, safeParamMap, e);
            return null;

                logger.info("Created storage bucket: {}", bucket);
            } catch (final Exception e1) {
                logger.warn("Failed to create storage bucket: {}", bucket, e1);
            }
        } catch (final Exception e) {
            if (logger.isDebugEnabled()) {
                logger.debug("Failed to check bucket: {}", bucket, e);
            }
        }
    }

    @Override
    public boolean isAvailable() {

            reload(updater, curlResponse.getContentAsStream());
        } catch (final IOException e) {
            throw new DictionaryException("Failed to parse " + path, e);
        }
    }

    /**
     * Reloads the character mapping items from the provided input stream.
     * Parses mapping rules in the format: input1,input2,... => output
     *

            }
        }
        return Result.FAILED;
    }

    /**
     * Enumeration representing the possible results of thumbnail image processing.
     */
    protected enum Result {
        /** Thumbnail was successfully generated */
        OK,
        /** Thumbnail generation failed due to processing errors */
        FAILED,
        /** Image dimensions do not meet validation requirements */

            if (logger.isDebugEnabled()) {
                logger.debug("Failed to process a scroll request.", e);
            }
            writeJsonResponse(HttpServletResponse.SC_BAD_REQUEST, e);
        } catch (final Exception e) {
            if (logger.isDebugEnabled()) {
                logger.debug("Failed to process a scroll request.", e);
            }

            reload(updater, curlResponse.getContentAsStream());
        } catch (final IOException e) {
            throw new DictionaryException("Failed to parse " + path, e);
        }
    }

    /**
     * Reloads the stemmer override dictionary from an input stream.
     *
     * @param updater An optional updater to apply changes.

                    builder.setCredentials(credentials);
                } catch (final IOException e) {
                    throw new StorageException("Failed to load GCS credentials from " + credentialsPath, e);
                }
            }
            // If no credentials path, uses default credentials (GOOGLE_APPLICATION_CREDENTIALS env var)
        }