Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 101 - 110 of 283 for synchronize (0.05 seconds)

The search processing time has exceeded the limit. The displayed results may be partial.

  1. android/guava-testlib/src/com/google/common/testing/TearDownStack.java

      }
    
      @Override
      public final void addTearDown(TearDown tearDown) {
        synchronized (lock) {
          stack.addFirst(checkNotNull(tearDown));
        }
      }
    
      /** Causes teardown to execute. */
      public final void runTearDown() {
        Throwable exception = null;
        List<TearDown> stackCopy;
        synchronized (lock) {
          stackCopy = new ArrayList<>(stack);
          stack.clear();
        }
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Wed Oct 01 13:14:50 GMT 2025
    - 2.7K bytes
    - Click Count (0)
  2. guava-testlib/src/com/google/common/testing/TearDownStack.java

      }
    
      @Override
      public final void addTearDown(TearDown tearDown) {
        synchronized (lock) {
          stack.addFirst(checkNotNull(tearDown));
        }
      }
    
      /** Causes teardown to execute. */
      public final void runTearDown() {
        Throwable exception = null;
        List<TearDown> stackCopy;
        synchronized (lock) {
          stackCopy = new ArrayList<>(stack);
          stack.clear();
        }
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Wed Oct 01 13:14:50 GMT 2025
    - 2.7K bytes
    - Click Count (0)
  3. android/guava/src/com/google/common/util/concurrent/ExecutionList.java

        // 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 (lock) {
          if (!executed) {
            runnables = new RunnableExecutorPair(runnable, executor, runnables);
            return;
          }
        }
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Tue Feb 10 11:51:21 GMT 2026
    - 6.9K bytes
    - Click Count (0)
  4. src/main/java/jcifs/smb1/netbios/Lmhosts.java

         *
         * @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) {
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Sat Aug 16 01:32:48 GMT 2025
    - 6K bytes
    - Click Count (0)
  5. fess-crawler/src/main/java/org/codelibs/fess/crawler/client/CrawlerClientCreator.java

         * 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);
    Created: Sun Apr 12 03:50:13 GMT 2026
    - Last Modified: Sun Jul 06 02:13:03 GMT 2025
    - 4.5K bytes
    - Click Count (0)
  6. src/main/java/jcifs/smb/SmbFileHandleImpl.java

        }
    
        /**
         * {@inheritDoc}
         *
         * @see jcifs.SmbFileHandle#close(long)
         */
        @Override
        public synchronized void close(final long lastWriteTime) throws CIFSException {
            closeInternal(lastWriteTime, true);
        }
    
        /**
         * @param lastWriteTime
         * @throws SmbException
         */
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Sun Aug 31 08:00:57 GMT 2025
    - 9.4K bytes
    - Click Count (1)
  7. src/main/java/org/codelibs/fess/app/web/base/login/EntraIdCredential.java

             * @param groups Array of group names.
             */
            public synchronized void setGroups(final String[] groups) {
                this.groups = groups;
            }
    
            /**
             * Sets the user's role assignments.
             * @param roles Array of role names.
             */
            public synchronized void setRoles(final String[] roles) {
                this.roles = roles;
            }
    
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Fri Nov 28 16:29:12 GMT 2025
    - 7.8K bytes
    - Click Count (0)
  8. android/guava-tests/test/com/google/common/collect/SynchronizedQueueTest.java

    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);
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Wed Jul 16 17:42:14 GMT 2025
    - 4.8K bytes
    - Click Count (0)
  9. android/guava-tests/test/com/google/common/collect/SynchronizedTableTest.java

          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
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Wed Jul 16 17:42:14 GMT 2025
    - 4.7K bytes
    - Click Count (0)
  10. android/guava-tests/test/com/google/common/util/concurrent/AbstractFutureBenchmarks.java

            executionList.execute();
          }
          return result;
        }
    
        /**
         * Following the contract of {@link AbstractQueuedSynchronizer} we create a private subclass to
         * hold the synchronizer. This synchronizer is used to implement the blocking and waiting calls
         * as well as to handle state changes in a thread-safe manner. The current state of the future
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Sat Mar 07 02:20:33 GMT 2026
    - 13.8K bytes
    - Click Count (0)
Back to Top