* forwards the calls to the underlying {@code Map}.
   */
  private static class CheckSetUpInvocationHandler implements InvocationHandler, Serializable {
    private final Map<String, String> map;
    private final AtomicBoolean setUpRan;

    CheckSetUpInvocationHandler(Map<String, String> map, AtomicBoolean setUpRan) {
      this.map = map;
      this.setUpRan = setUpRan;
    }

    @Override

/**
 * Handles failover and recovery for multi-channel connections
 */
public class ChannelFailover {

    private static final Logger log = LoggerFactory.getLogger(ChannelFailover.class);

    private final ChannelManager manager;
    private final ExecutorService executor;
    private final ConcurrentMap<String, FailoverState> failoverStates;

    /**
     * Create channel failover handler
     *

{* ../../docs_src/path_params_numeric_validations/tutorial004_an_py310.py hl[10] *}

## Validações numéricas: maior que e menor que ou igual { #number-validations-greater-than-and-less-than-or-equal }

O mesmo se aplica a:

* `gt`: maior que (`g`reater `t`han)
* `le`: menor que ou igual (`l`ess than or `e`qual)

{* ../../docs_src/path_params_numeric_validations/tutorial005_an_py310.py hl[10] *}

@RunWith(Parameterized.class)
@NullUnmarked
public final class GraphEquivalenceTest {
  private static final Integer N1 = 1;
  private static final Integer N2 = 2;
  private static final Integer N3 = 3;

  private final EdgeType edgeType;
  private final MutableGraph<Integer> graph;

  // add parameters: directed/undirected
  @Parameters

public final class mockwebserver3/junit4/MockWebServerRule : org/junit/rules/ExternalResource {
	public fun <init> ()V
	public final fun getServer ()Lmockwebserver3/MockWebServer;

import org.jspecify.annotations.Nullable;

@NullUnmarked
public class SynchronizedTableTest extends AbstractTableTest<Character> {
  private static final class TestTable<R, C, V> implements Table<R, C, V>, Serializable {
    private final Table<R, C, V> delegate = HashBasedTable.create();
    private final Object mutex = new Object[0]; // something Serializable

    @Override
    public String toString() {
      assertTrue(Thread.holdsLock(mutex));

        final int threadCount = 10;
        final Thread[] threads = new Thread[threadCount];
        final InvertibleCryptographer[] invertibles = new InvertibleCryptographer[threadCount];
        final OneWayCryptographer[] oneWays = new OneWayCryptographer[threadCount];

        for (int i = 0; i < threadCount; i++) {
            final int index = i;
            threads[i] = new Thread(() -> {

     * Constructs an instance.
     *
     * @param pattern
     *            the pattern for time
     */
    public TimeConverter(final String pattern) {
        assertArgumentNotEmpty("pattern", pattern);
        this.pattern = pattern;
    }

    @Override
    public Object getAsObject(final String value) {
        if (isEmpty(value)) {
            return null;
        }

public class DirectoryLeaseManager {

    private static final Logger log = LoggerFactory.getLogger(DirectoryLeaseManager.class);

    private final CIFSContext context;
    private final LeaseManager baseLeaseManager;
    private final ConcurrentHashMap<String, DirectoryCacheEntry> directoryCache;
    private final ConcurrentHashMap<Smb2LeaseKey, String> leaseToPath;
    private final ScheduledExecutorService scheduler;

        // reset everything
        getFileSystemOperations().delete {
            it.delete(baseDir)
        }
        cwd.mkdirs()
        final String realExecutable
        final List<Object> realArgs = new ArrayList<>()
        final Map<String, Object> realEnv = environment
        // We need to choose which executable we are using. In shell mode, or when we