Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 461 - 470 of 890 for thread (0.07 seconds)

  1. android/guava/src/com/google/common/io/FileBackedOutputStream.java

     *       #FileBackedOutputStream(int, boolean) the two-arg constructor} with {@code true} for the
     *       second parameter. Relying on this second approach is discouraged.
     * </ul>
     *
     * <p>This class is thread-safe.
     *
     * @author Chris Nokleberg
     * @since 1.0
     */
    @Beta
    @J2ktIncompatible
    @GwtIncompatible
    @J2ObjCIncompatible
    public final class FileBackedOutputStream extends OutputStream {
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Sat Mar 07 17:30:49 GMT 2026
    - 12.4K bytes
    - Click Count (0)
  2. src/main/java/jcifs/smb/SmbCopyUtil.java

                            }
                            w.checkException();
    
                            if (read <= 0) {
                                break;
                            }
    
                            w.write(b[i], read, fos);
                        }
    
                        i = i == 1 ? 0 : 1;
                        off += read;
                    }
    
                    if (log.isDebugEnabled()) {
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Sat Aug 16 01:32:48 GMT 2025
    - 16.6K bytes
    - Click Count (0)
  3. src/main/java/org/codelibs/core/lang/ClassUtil.java

         */
        public static <T> Class<T> forName(final String className) throws ClassNotFoundRuntimeException {
            assertArgumentNotEmpty("className", className);
    
            return forName(className, Thread.currentThread().getContextClassLoader());
        }
    
        /**
         * Returns the {@link Class} object associated with the class or interface with the given string name,
         * using the specified class loader.
         *
    Created: Fri Apr 03 20:58:12 GMT 2026
    - Last Modified: Thu Jul 31 08:16:49 GMT 2025
    - 25.6K bytes
    - Click Count (0)
  4. android/guava/src/com/google/common/util/concurrent/AbstractTransformFuture.java

        try {
          transformResult = doTransform(localFunction, sourceResult);
        } catch (Throwable t) {
          restoreInterruptIfIsInterruptedException(t);
          // This exception is irrelevant in this thread, but useful for the client.
          setException(t);
          return;
        } finally {
          function = null;
        }
    
        /*
         * If set()/setValue() throws an Error, we let it propagate. Why? The most likely Error is a
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Thu Feb 20 18:03:37 GMT 2025
    - 10.8K bytes
    - Click Count (0)
  5. android/guava/src/com/google/common/collect/Sets.java

      }
    
      /**
       * Creates a thread-safe set backed by a hash map. The set is backed by a {@link
       * ConcurrentHashMap} instance, and thus carries the same concurrency guarantees.
       *
       * <p>Unlike {@code HashSet}, this class does NOT allow {@code null} to be used as an element. The
       * set is serializable.
       *
       * @return a new, empty thread-safe {@code Set}
       * @since 15.0
       */
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Feb 23 19:19:10 GMT 2026
    - 81.4K bytes
    - Click Count (0)
  6. android/guava-tests/test/com/google/common/io/MoreFilesTest.java

          MoreFiles.deleteDirectoryContents(symlink, ALLOW_INSECURE);
          assertEquals(0, MoreFiles.listFiles(dir).size());
        }
      }
    
      /**
       * This test attempts to create a situation in which one thread is constantly changing a file from
       * being a real directory to being a symlink to another directory. It then calls
       * deleteDirectoryContents thousands of times on a directory whose subtree contains the file
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Tue Mar 17 19:26:39 GMT 2026
    - 26.6K bytes
    - Click Count (0)
  7. src/main/java/org/codelibs/fess/Constants.java

        public static final String INCREMENTAL_CRAWLING_PROPERTY = "crawling.incremental";
    
        /** Property key for crawling thread count configuration. */
        public static final String CRAWLING_THREAD_COUNT_PROPERTY = "crawling.thread.count";
    
        /** Property key for crawling user agent configuration. */
        public static final String CRAWLING_USER_AGENT_PROPERTY = "crawling.user.agent";
    
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Sat Mar 28 11:55:54 GMT 2026
    - 35.8K bytes
    - Click Count (0)
  8. README.md

    - **Logging Abstraction** (`org.codelibs.core.log`) - Flexible logging system supporting JCL (Jakarta Commons Logging) and JUL (Java Util Logging)
    - **Concurrent Utilities** (`org.codelibs.core.concurrent`) - Thread-safe collections and concurrency helpers using modern concurrent APIs
    - **Crypto & Security** (`org.codelibs.core.crypto`, `org.codelibs.core.security`) - Basic cryptographic utilities, message digest operations, and secure random generation
    Created: Fri Apr 03 20:58:12 GMT 2026
    - Last Modified: Sun Aug 31 02:56:02 GMT 2025
    - 12.7K bytes
    - Click Count (0)
  9. guava-tests/test/com/google/common/collect/ConcurrentHashMultisetTest.java

        int countToRemove = 30;
        AtomicInteger current = new AtomicInteger(countToRemove);
    
        when(backingMap.get(KEY)).thenReturn(current);
        // it's ok if removal fails: another thread may have done the remove
        when(backingMap.remove(KEY, current)).thenReturn(false);
    
        assertEquals(countToRemove, multiset.remove(KEY, countToRemove));
        assertEquals(0, current.get());
      }
    
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Thu Mar 12 17:47:10 GMT 2026
    - 16.3K bytes
    - Click Count (0)
  10. android/guava-testlib/src/com/google/common/testing/GcFinalization.java

        //
        // TODO(user): Consider using
        // java/lang/management/OperatingSystemMXBean.html#getSystemLoadAverage()
        //
        // TODO(user): Consider scaling by number of mutator threads,
        // e.g. using Thread#activeCount()
        return max(10L, Runtime.getRuntime().totalMemory() / (32L * 1024L * 1024L));
      }
    
      /**
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Thu Mar 12 20:19:19 GMT 2026
    - 12.3K bytes
    - Click Count (0)
Back to Top