Search Options

Results per page
Sort
Preferred Languages
Advance

Results 121 - 130 of 284 for Synchronized (0.12 sec)

  1. src/main/java/org/codelibs/core/exception/InstantiationRuntimeException.java

            super("ECL0041", asArray(targetClass.getName(), cause), cause);
            this.targetClass = targetClass;
        }
    
        @Override
        public synchronized InstantiationRuntimeException initCause(final Throwable cause) {
            return (InstantiationRuntimeException) super.initCause(cause);
        }
    
        /**
         * Returns the target class.
         *
    Registered: Fri Sep 05 20:58:11 UTC 2025
    - Last Modified: Sat Jul 05 00:11:05 UTC 2025
    - 1.8K bytes
    - Viewed (0)
  2. android/guava/src/com/google/common/util/concurrent/LazyLogger.java

         * That may introduce an extra class for each lambda (currently a dozen).
         */
        Logger local = logger;
        if (local != null) {
          return local;
        }
        synchronized (lock) {
          local = logger;
          if (local != null) {
            return local;
          }
          return logger = Logger.getLogger(loggerName);
        }
      }
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Sun Dec 22 03:38:46 UTC 2024
    - 1.9K bytes
    - Viewed (0)
  3. src/main/java/jcifs/smb1/smb1/TransCallNamedPipeResponse.java

        int readDataWireFormat(final byte[] buffer, final int bufferIndex, final int len) {
            if (pipe.pipeIn != null) {
                final TransactNamedPipeInputStream in = (TransactNamedPipeInputStream) pipe.pipeIn;
                synchronized (in.lock) {
                    in.receive(buffer, bufferIndex, len);
                    in.lock.notify();
                }
            }
            return len;
        }
    
        @Override
        public String toString() {
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Thu Aug 14 07:14:38 UTC 2025
    - 2.1K bytes
    - Viewed (0)
  4. fess-crawler/src/main/java/org/codelibs/fess/crawler/interval/impl/HostIntervalController.java

                }
                final AtomicLong lastTime = lastTimes.putIfAbsent(host, new AtomicLong(SystemUtil.currentTimeMillis()));
                if (lastTime == null) {
                    return;
                }
                synchronized (lastTime) {
                    while (true) {
                        final long currentTime = SystemUtil.currentTimeMillis();
                        final long delayTime = lastTime.get() + delayMillisBeforeProcessing - currentTime;
    Registered: Sun Sep 21 03:50:09 UTC 2025
    - Last Modified: Sun Jul 06 02:13:03 UTC 2025
    - 4.2K bytes
    - Viewed (0)
  5. fess-crawler/src/main/java/org/codelibs/fess/crawler/service/impl/DataServiceImpl.java

         */
        @Override
        public void store(final AccessResultImpl<Long> accessResult) {
            if (accessResult == null) {
                throw new CrawlerSystemException("AccessResult is null.");
            }
    
            synchronized (idCountLock) {
                idCount++;
                accessResult.setId(idCount);
                AccessResultData<Long> accessResultData = accessResult.getAccessResultData();
                if (accessResultData == null) {
    Registered: Sun Sep 21 03:50:09 UTC 2025
    - Last Modified: Sun Jul 06 02:13:03 UTC 2025
    - 6.8K bytes
    - Viewed (0)
  6. src/main/java/org/codelibs/core/beans/factory/BeanDescFactory.java

            }
            return beanDesc;
        }
    
        /**
         * Performs initialization.
         */
        public static void initialize() {
            synchronized (BeanDescFactory.class) {
                if (!initialized) {
                    DisposableUtil.add(BeanDescFactory::clear);
                    initialized = true;
                }
            }
        }
    
        /**
    Registered: Fri Sep 05 20:58:11 UTC 2025
    - Last Modified: Thu Jul 31 08:16:49 UTC 2025
    - 2.8K bytes
    - Viewed (0)
  7. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/http1/Http1ExchangeCodec.kt

            writeUtf8("\r\n")
            write(source, byteCount)
            writeUtf8("\r\n")
          }
        }
    
        @Synchronized
        override fun flush() {
          if (closed) return // Don't throw; this stream might have been closed on the caller's behalf.
          socket.sink.flush()
        }
    
        @Synchronized
        override fun close() {
          if (closed) return
          closed = true
          socket.sink.writeUtf8("0\r\n\r\n")
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Thu Jul 31 04:18:40 UTC 2025
    - 17.5K bytes
    - Viewed (7)
  8. src/main/java/org/codelibs/fess/exception/UserRoleLoginException.java

         * This prevents stack trace generation for this exception type.
         *
         * @return null to skip stack trace generation
         */
        @Override
        public synchronized Throwable fillInStackTrace() {
            return null;
        }
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Thu Jul 17 08:28:31 UTC 2025
    - 1.9K bytes
    - Viewed (0)
  9. src/main/java/jcifs/smb1/netbios/SocketOutputStream.java

    import java.io.OutputStream;
    
    class SocketOutputStream extends FilterOutputStream {
    
        SocketOutputStream(final OutputStream out) {
            super(out);
        }
    
        @Override
        public synchronized void write(final byte[] b, int off, final int len) throws IOException {
            if (len > 0xFFFF) {
                throw new IOException("write too large: " + len);
            }
            if (off < 4) {
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Thu Aug 14 07:14:38 UTC 2025
    - 1.7K bytes
    - Viewed (0)
  10. src/main/java/jcifs/smb/SmbPipeHandleImpl.java

         * @see jcifs.SmbPipeHandle#isStale()
         */
        @Override
        public boolean isStale() {
            return !this.open || this.handle != null && !this.handle.isValid();
        }
    
        @Override
        public synchronized SmbFileHandleImpl ensureOpen() throws CIFSException {
            if (!this.open) {
                throw new SmbException("Pipe handle already closed");
            }
    
            if (!isOpen()) {
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Sun Aug 31 08:00:57 UTC 2025
    - 10.2K bytes
    - Viewed (0)
Back to top