for (Thread thread : threads) {
            try {
                thread.join();
            } catch (InterruptedException e) {
                fail("Thread interrupted: " + e.getMessage());
            }
        }

        // Verify all threads got the same instances
        for (int i = 0; i < threadCount; i++) {
            assertSame(invertibleCryptographer, invertibles[i]);

            // Log the exception for debugging purposes but don't fail the test
            System.out.println("Expected exception in test environment: " + t.getClass().getSimpleName() + ": " + t.getMessage());

            // Verify that it's a system-related exception, not a method signature issue
            assertTrue("Exception should be system-related", t instanceof RuntimeException || t instanceof AssertionError

    }

    assertEquals(1, logHandler.getStoredLogRecords().size());
    assertEquals(
        "Exception while executing callback: MyListener custom-label",
        logHandler.getStoredLogRecords().get(0).getMessage());
  }

  public void testEnqueueAndDispatch_multithreaded() throws InterruptedException {
    Object listener = new Object();
    ExecutorService service = newFixedThreadPool(4);

    }

    assertEquals(1, logHandler.getStoredLogRecords().size());
    assertEquals(
        "Exception while executing callback: MyListener custom-label",
        logHandler.getStoredLogRecords().get(0).getMessage());
  }

  public void testEnqueueAndDispatch_multithreaded() throws InterruptedException {
    Object listener = new Object();
    ExecutorService service = newFixedThreadPool(4);

            if (!ModelProblem.Severity.WARNING.equals(req.getSeverity())) {
                errors.add(new ProfileActivationException(req.getMessage(), req.getException()));
            }
        });

        if (!errors.isEmpty()) {
            throw errors.get(0);
        }

        return profiles;
    }

    /* (non-Javadoc)

            pos += writeSecurityBufferContent(type1, pos, wsOffOff, workstation);
            return type1;
        } catch (final IOException ex) {
            throw new IllegalStateException(ex.getMessage());
        }
    }

    @Override
    public String toString() {
        final String suppliedDomainString = getSuppliedDomain();
        final String suppliedWorkstationString = getSuppliedWorkstation();

            assertNotNull(NetbiosName.class.getMethod("getScope"));
            assertNotNull(NetbiosName.class.getMethod("getNameType"));
        } catch (NoSuchMethodException e) {
            fail("Method not found: " + e.getMessage());
        }
    }

    @Test
    @DisplayName("Should handle getName() method")
    void testGetName() {
        // Given
        String testName = "TESTSERVER";

                    return;
                }
                try {
                    session.transport.wait();
                } catch (final InterruptedException ie) {
                    throw new SmbException(ie.getMessage(), ie);
                }
            }
            connectionState = 1; // trying ...

            try {
                /* The hostname to use in the path is only known for

        Exception exception = assertThrows(CIFSException.class, () -> context.encryptMessage(largeMessage, 2L));
        assertTrue(exception.getMessage().contains("rotation") || exception.getMessage().contains("exceeded"),
                "Should indicate key rotation issue: " + exception.getMessage());

        context.close();
    }

    @Test
    @DisplayName("Should handle multiple closes gracefully")

        try {
            SsoResponseType.valueOf("INVALID");
            fail("Expected IllegalArgumentException");
        } catch (IllegalArgumentException e) {
            // Expected exception
            assertTrue(e.getMessage().contains("INVALID"));
        }
    }

    public void test_valueOf_null() {
        // Test valueOf with null throws exception
        try {
            SsoResponseType.valueOf(null);