// Lock while we check state. We must maintain the lock while adding the new pair so that
    // another thread can't run the list out from under us. We only add to the list if we have not
    // yet started execution.
    synchronized (this) {
      if (!executed) {
        runnables = new RunnableExecutorPair(runnable, executor, runnables);
        return;
      }
    }

     * @param a the authenticator to set as default
     */

    public synchronized static void setDefault(final NtlmAuthenticator a) {
        if (auth != null) {
            return;
        }
        auth = a;
    }

    /**
     * Gets the URL that is requesting authentication.

- Added pod version skew strategy for seccomp profile to synchronize the deprecated annotations with the new API Server fields. Please see the corresponding section [in the KEP](https://github.com/kubernetes/enhancements/blob/master/keps/sig-node/135-seccomp/README.md#version-skew-strategy) for more detailed explanations....

            }
        }

        public synchronized void recordSuccess(long responseTimeMs) {
            getCurrentBucket().recordSuccess(responseTimeMs);
        }

        public synchronized void recordFailure() {
            getCurrentBucket().recordFailure();
        }

        public synchronized WindowMetrics getMetrics() {
            long now = System.currentTimeMillis();

      synchronized (future) {
        if (future.waitersField == expect) {
          future.waitersField = update;
          return true;
        }
        return false;
      }
    }

    @Override
    boolean casListeners(
        AbstractFutureState<?> future, @Nullable Listener expect, Listener update) {
      synchronized (future) {

     * Registers a CrawlerClientFactory with this creator.
     * All existing client mappings will be loaded into the new factory.
     * @param crawlerClientFactory The CrawlerClientFactory to register.
     */
    public synchronized void register(final CrawlerClientFactory crawlerClientFactory) {
        clientMap.entrySet().stream().forEach(e -> load(crawlerClientFactory, e.getKey(), e.getValue()));
        clientFactoryList.add(crawlerClientFactory);

     *
     * @param host the hostname to resolve
     * @return the resolved NbtAddress or null if not found
     */

    public synchronized static NbtAddress getByName(final String host) {
        return getByName(new Name(host, 0x20, null));
    }

    synchronized static NbtAddress getByName(final Name name) {
        NbtAddress result = null;

        try {
            if (FILENAME != null) {

once-per-session org.apache.maven maven-plugin-api jar 2.0 org/apache/maven/plugin/coreit/ItMojo.class package org.apache.maven.plugin.coreit; public synchronized class ItMojo extends org.apache.maven.plugin.AbstractMojo { public void ItMojo(); public void execute(); } org/apache/maven/plugin/coreit/TestMojo.class package org.apache.maven.plugin.coreit; public synchronized class TestMojo extends org.apache.maven.plugin.AbstractMojo { public void TestMojo(); public void execute(); } pom.xml 4.0.0 org.apache.maven.plugins...

import org.jspecify.annotations.Nullable;

/**
 * Tests for {@link Synchronized#queue} and {@link Queues#synchronizedQueue}.
 *
 * @author Kurt Alfred Kluever
 */
@NullUnmarked
public class SynchronizedQueueTest extends TestCase {

  protected Queue<String> create() {
    TestQueue<String> inner = new TestQueue<>();
    Queue<String> outer = Synchronized.queue(inner, inner.mutex);

      delegate.clear();
    }

    @Override
    public Collection<V> values() {
      assertTrue(Thread.holdsLock(mutex));
      /* TODO: verify that the Collection is also synchronized? */
      return delegate.values();
    }

    @Override
    public Set<Cell<R, C, V>> cellSet() {
      assertTrue(Thread.holdsLock(mutex));
      return delegate.cellSet();
    }

    @Override