if (bufferQueue.offer(buf)) { // O(1) operation
                queueSize.incrementAndGet();
            }
        }
        // If queue is full, let the buffer be garbage collected
    }

    /**
     * Get current cache statistics for monitoring
     * @return formatted statistics string
     */
    public static String getCacheStatistics() {

import java.io.EOFException
import java.net.InetAddress
import java.net.UnknownHostException
import okio.Buffer
import okio.ByteString
import okio.utf8Size

/**
 * Trivial Dns Encoder/Decoder, basically ripped from Netty full implementation.
 */
internal object DnsRecordCodec {
  private const val SERVFAIL = 2
  private const val NXDOMAIN = 3
  const val TYPE_A = 0x0001
  const val TYPE_AAAA = 0x001c
  private const val TYPE_PTR = 0x000c

     *
     * @return the domain name
     */
    public String getDomainName() {
        if (origin_server != null) {
            resolveWeak();
        }
        if (type == SID_TYPE_UNKNOWN) {
            final String full = toString();
            return full.substring(0, full.length() - getAccountName().length() - 1);
        }
        return domainName;
    }

    /**

    /** No mapping between account names and security IDs was done */
    int NT_STATUS_NONE_MAPPED = 0xC0000073;
    /** The security ID structure is invalid */
    int NT_STATUS_INVALID_SID = 0xC0000078;
    /** The disk is full */
    int NT_STATUS_DISK_FULL = 0xC000007f;
    /** Insufficient resources are available to complete the request */
    int NT_STATUS_INSUFFICIENT_RESOURCES = 0xC000009a;

        Map<String, Object> docMap = new HashMap<>();
        docMap.put("id", "doc123");

        // Since createTask depends on FessConfig, it may not work properly
        // in unit tests without full container
        try {
            generator.createTask("/path/to/thumb.jpg", docMap);
        } catch (Exception e) {
            // Expected when FessConfig is not available
        }
    }

    /**
     * Initializes the form with default null values.
     * This method resets all fields to their default state for creating a new entry.
     */
    public void initialize() {
        id = null;
        url = null;
        threadName = null;
        errorName = null;
        errorLog = null;
        errorCount = null;
        lastAccessTime = null;
        configId = null;
    }

    tag: Long,
    forceConstructed: Boolean? = null,
  ): BasicDerAdapter<T> {
    val codec =
      object : BasicDerAdapter.Codec<T> {
        override fun decode(reader: DerReader): T = fromDer(reader)

        override fun encode(
          writer: DerWriter,
          value: T,
        ) {
          toDer(writer, value)
          if (forceConstructed != null) {
            writer.constructed = forceConstructed

   *   public boolean isDone() {
   *     return ref.get() == null;
   *   }
   * });
   * }
   *
   * @throws RuntimeException if timed out or interrupted while waiting
   */
  public static void awaitClear(WeakReference<?> ref) {
    awaitDone(() -> ref.get() == null);
  }

  /**
   * Tries to perform a "full" garbage collection cycle (including processing of weak references and

 * </ul>
 *
 * @since 4.0.0
 */
@Experimental
public interface OsService extends Service {
    /**
     * Returns the OS full name as reported by the system property "os.name".
     * The value is converted to lowercase for consistency.
     *
     * @return the operating system name (never null)
     */
    @Nonnull
    String name();

    /**
     * Returns the OS architecture as reported by the system property "os.arch".

    static Stream<Arguments> byteEncodableArgs() {
        return Stream.of(
                // srcLen, off, len, dstIndex
                Arguments.of(makeSeq(8), 0, 8, 0), // full copy at index 0
                Arguments.of(makeSeq(10), 2, 5, 3), // middle slice, non-zero dst index
                Arguments.of(makeSeq(4), 4, 0, 0), // zero-length slice at end