okayToRun.await();
            } catch (InterruptedException e) {
              Thread.currentThread().interrupt();
              throw new RuntimeException(e);
            }
            runCalled.getAndIncrement();
          }
        },
        directExecutor());
    Runnable execute =
        new Runnable() {
          @Override
          public void run() {
            list.execute();
          }

     * @return a string representing the bulk line for OpenSearch indexing
     * @throws SuggesterException if an I/O error occurs during the creation of the bulk line
     */
    public static String createBulkLine(final String index, final String type, final SuggestItem item) {
        if (item == null || item.getId() == null || item.getText() == null) {
            throw new SuggesterException("Invalid SuggestItem: item, id, or text is null");
        }

    }

    /**
     * Get the address the service is listening on
     *
     * @return the service address
     * @throws IOException if address cannot be determined
     */
    public InetAddress getAddress() throws IOException {
        if (serverSocket == null) {
            throw new IOException("Service not started");
        }
        return InetAddress.getLocalHost();
    }

    /**

     *
     * @param defaultEncoding the default encoding to set
     * @throws IllegalArgumentException if the default encoding is blank
     */
    public void setDefaultEncoding(final String defaultEncoding) {
        if (StringUtil.isBlank(defaultEncoding)) {
            throw new IllegalArgumentException("Default encoding must not be blank.");
        }
        this.defaultEncoding = defaultEncoding;

        @Override
        public long process() {
            return returnValue;
        }
    }

    // Test class that throws exception
    private static class ExceptionScoreBooster extends ScoreBooster {
        @Override
        public long process() {
            throw new RuntimeException("Test exception");
        }
    }

    // Test class with priority tracking

            // Submit a write that will throw inside the writer thread
            w.write(payload, payload.length, out);

            // Give the writer thread time to process and set exception
            w.wait(100);
        }

        // Wait a bit more to ensure exception is captured
        Thread.sleep(100);

        // Act + Assert: checkException should throw the SmbException captured by the thread

            return created;
        } catch (final Exception e) {
            if (logger.isDebugEnabled()) {
                logger.debug("Failed to create index. index: {}", index, e);
            }
            throw new SuggesterException("Failed to create index.", e);
        }
    }

    /**
     * Creates a new index and replaces the current update alias with the new index.
     */
    public void createNextIndex() {

              @Override
              public Collection<String> create(String[] elements) {
                // TODO: MinimalCollection should perhaps throw
                for (Object element : elements) {
                  if (element == null) {
                    throw new NullPointerException();
                  }
                }
                return MinimalCollection.of(elements);
              }
            })

     *
     * @param key 16-byte array
     * @throws IllegalArgumentException if key is not 16 bytes
     */
    public Smb2LeaseKey(byte[] key) {
        if (key == null) {
            throw new IllegalArgumentException("Lease key cannot be null");
        }
        if (key.length != LEASE_KEY_SIZE) {
            throw new IllegalArgumentException("Lease key must be 16 bytes, got " + key.length);
        }

    public void testUpdateNonExistentSession() throws CIFSException {
        // With enforcement disabled, this should log a warning but not throw
        PreauthIntegrityService lenientService = new PreauthIntegrityService(secureRandom, PreauthIntegrityService.HASH_ALGO_SHA512, false);

        // Should not throw exception
        lenientService.updatePreauthHash("non-existent", "test".getBytes());