Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 211 - 220 of 327 for Synchronized (0.06 seconds)

  1. android/guava/src/com/google/common/util/concurrent/TimeoutFuture.java

        }
      }
    
      private static final class TimeoutFutureException extends TimeoutException {
        private TimeoutFutureException(String message) {
          super(message);
        }
    
        @Override
        public synchronized Throwable fillInStackTrace() {
          setStackTrace(new StackTraceElement[0]);
          return this; // no stack trace, wouldn't be useful anyway
        }
      }
    
      @Override
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Sun Dec 22 03:38:46 GMT 2024
    - 8K bytes
    - Click Count (0)
  2. src/test/java/org/codelibs/fess/exception/UserRoleLoginExceptionTest.java

            // Test thread safety of fillInStackTrace method
            UserRoleLoginException exception = new UserRoleLoginException(RootAction.class);
    
            // Create multiple threads to test synchronized method
            Thread thread1 = new Thread(() -> {
                Throwable result = exception.fillInStackTrace();
                assertNull(result);
            });
    
            Thread thread2 = new Thread(() -> {
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Fri Mar 13 23:01:26 GMT 2026
    - 11K bytes
    - Click Count (0)
  3. src/main/java/org/codelibs/fess/exec/SuggestCreator.java

            }
    
            logger.info("Finished SuggestCreator.");
            System.exit(exitCode);
        }
    
        private static void destroyContainer() {
            TimeoutManager.getInstance().stop();
            synchronized (SingletonLaContainerFactory.class) {
                SingletonLaContainerFactory.destroy();
            }
        }
    
        private static int process(final Options options) {
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Thu Mar 26 02:24:08 GMT 2026
    - 12.1K bytes
    - Click Count (0)
  4. src/main/java/jcifs/internal/smb1/ServerMessageBlock.java

            this.received = true;
            synchronized (this) {
                notifyAll();
            }
        }
    
        /**
         * {@inheritDoc}
         *
         * @see jcifs.util.transport.Response#exception(java.lang.Exception)
         */
        @Override
        public void exception(final Exception e) {
            this.exception = e;
            synchronized (this) {
                notifyAll();
            }
        }
    
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Sat Aug 16 01:32:48 GMT 2025
    - 38.9K bytes
    - Click Count (0)
  5. src/test/java/jcifs/smb/PreauthIntegrityTest.java

            when(address.getHostName()).thenReturn("testhost");
    
            transport = new SmbTransportImpl(context, address, 445, null, 0, false);
        }
    
        /**
         * Test that pre-auth integrity hash is properly synchronized
         */
        @Test
        @DisplayName("Pre-auth integrity hash should be thread-safe")
        void testPreauthHashThreadSafety() throws Exception {
            // Setup SMB3.1.1 negotiation
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Sat Aug 30 05:58:03 GMT 2025
    - 10.5K bytes
    - Click Count (0)
  6. guava/src/com/google/common/collect/ImmutableSortedSet.java

       *
       * <p>This method is not type-safe, as it may be called on elements that are not mutually
       * comparable.
       *
       * <p>This method is safe to use even when {@code elements} is a synchronized or concurrent
       * collection that is currently being modified by another thread.
       *
       * @throws ClassCastException if the elements are not mutually comparable
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Tue Sep 23 17:50:58 GMT 2025
    - 39.1K bytes
    - Click Count (0)
  7. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/http2/Http2Stream.kt

          while (true) {
            var tryAgain = false
            var readBytesDelivered = -1L
            var errorExceptionToDeliver: IOException? = null
    
            // 1. Decide what to do in a synchronized block.
    
            withLock {
              val doReadTimeout = doReadTimeout()
              if (doReadTimeout) {
                readTimeout.enter()
              }
              try {
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Mon Jul 07 18:57:05 GMT 2025
    - 22.4K bytes
    - Click Count (0)
  8. src/main/java/jcifs/smb/SmbTreeHandleImpl.java

        }
    
        /**
         * {@inheritDoc}
         *
         * @see jcifs.SmbTreeHandle#close()
         */
        @Override
        public synchronized void close() {
            release();
        }
    
        /**
         * @return tree handle with increased usage count
         */
        public SmbTreeHandleImpl acquire() {
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Sun Aug 31 08:00:57 GMT 2025
    - 11.1K bytes
    - Click Count (0)
  9. compat/maven-compat/src/main/java/org/apache/maven/project/interpolation/AbstractStringBasedModelInterpolator.java

                throws ModelInterpolationException {
            if (!src.contains("${")) {
                return src;
            }
    
            Logger logger = getLogger();
    
            String result = src;
            synchronized (this) {
                for (ValueSource vs : valueSources) {
                    interpolator.addValueSource(vs);
                }
    
                for (InterpolationPostProcessor postProcessor : postProcessors) {
    Created: Sun Apr 05 03:35:12 GMT 2026
    - Last Modified: Fri Jun 06 14:28:57 GMT 2025
    - 13.6K bytes
    - Click Count (0)
  10. cmd/erasure-healing-common_test.go

    			t.Errorf("Unexpected error: %v", dataErrsPerDisk[diskIndex])
    		}
    
    		if disk == nil {
    			t.Errorf("Drive erroneously filtered, driveIndex: %d", diskIndex)
    		}
    	}
    
    	// Test 2: Not synchronized modtime
    	erasureDisks = s.getDisks()
    	partsMetadataBackup := partsMetadata[0]
    	partsMetadata[0].ModTime = partsMetadata[0].ModTime.Add(-1 * time.Hour)
    
    	errs = make([]error, len(erasureDisks))
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 22.4K bytes
    - Click Count (0)
Back to Top