Search Options

Results per page
Sort
Preferred Languages
Advance

Results 641 - 650 of 796 for Threads (0.04 sec)

  1. internal/s3select/csv/reader.go

    type queueItem struct {
    	input []byte          // raw input sent to the worker
    	dst   chan [][]string // result of block decode
    	err   error           // any error encountered will be set here
    }
    
    // Read - reads single record.
    // Once Read is called the previous record should no longer be referenced.
    func (r *Reader) Read(dst sql.Record) (sql.Record, error) {
    	// If we have have any records left, return these before any error.
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Tue May 27 15:19:03 UTC 2025
    - 8.8K bytes
    - Viewed (0)
  2. internal/event/target/amqp.go

    		return err
    	}
    	ch, confirms, err := target.channel()
    	if err != nil {
    		return err
    	}
    	defer ch.Close()
    
    	return target.send(eventData, ch, confirms)
    }
    
    // SendFromStore - reads an event from store and sends it to AMQP091.
    func (target *AMQPTarget) SendFromStore(key store.Key) error {
    	if err := target.init(); err != nil {
    		return err
    	}
    
    	ch, confirms, err := target.channel()
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Thu Aug 21 04:25:07 UTC 2025
    - 10K bytes
    - Viewed (0)
  3. android/guava/src/com/google/common/util/concurrent/FuturesGetChecked.java

     * the License.
     */
    
    package com.google.common.util.concurrent;
    
    import static com.google.common.base.Preconditions.checkArgument;
    import static java.lang.Thread.currentThread;
    import static java.util.Arrays.asList;
    
    import com.google.common.annotations.GwtIncompatible;
    import com.google.common.annotations.J2ktIncompatible;
    import com.google.common.annotations.VisibleForTesting;
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Sat Aug 09 01:14:59 UTC 2025
    - 10.2K bytes
    - Viewed (0)
  4. android/guava/src/com/google/common/io/ByteSource.java

          return ByteStreams.copy(in, out);
        } catch (Throwable e) {
          throw closer.rethrow(e);
        } finally {
          closer.close();
        }
      }
    
      /**
       * Reads the full contents of this byte source as a byte array.
       *
       * @throws IOException if an I/O error occurs while reading from this source
       */
      public byte[] read() throws IOException {
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Mon Sep 08 18:35:13 UTC 2025
    - 25.7K bytes
    - Viewed (0)
  5. src/main/java/jcifs/internal/smb2/lease/DirectoryCacheEntry.java

    import java.util.concurrent.atomic.AtomicInteger;
    import java.util.concurrent.locks.ReadWriteLock;
    import java.util.concurrent.locks.ReentrantReadWriteLock;
    
    /**
     * Cache entry for directory contents with thread-safe operations
     */
    public class DirectoryCacheEntry {
    
        private final String directoryPath;
        private final Smb2LeaseKey leaseKey;
        private final long createTime;
        private volatile long lastUpdateTime;
    Registered: Sat Dec 20 13:44:44 UTC 2025
    - Last Modified: Sat Aug 23 02:21:31 UTC 2025
    - 11.4K bytes
    - Viewed (0)
  6. impl/maven-core/src/main/java/org/apache/maven/internal/impl/SisuDiBridgeModule.java

            injector.bindInstance(Injector.class, injector);
            bind(Injector.class).toInstance(injector);
            bind(SisuDiBridgeModule.class).toInstance(this);
            ClassLoader classLoader = Thread.currentThread().getContextClassLoader();
            if (classLoader == null) {
                classLoader = getClass().getClassLoader();
            }
            if (discover) {
                injector.discover(classLoader);
            }
    Registered: Sun Dec 28 03:35:09 UTC 2025
    - Last Modified: Wed Sep 17 16:01:38 UTC 2025
    - 11.4K bytes
    - Viewed (0)
  7. okhttp/src/jvmTest/kotlin/okhttp3/ServerTruncatesRequestTest.kt

        override fun contentType(): MediaType? = null
    
        override fun writeTo(sink: BufferedSink) {
          for (i in 0 until 50) {
            sink.writeUtf8("abc")
            sink.flush()
            Thread.sleep(100)
          }
          fail("")
        }
      }
    Registered: Fri Dec 26 11:42:13 UTC 2025
    - Last Modified: Tue Nov 04 19:13:52 UTC 2025
    - 10.4K bytes
    - Viewed (0)
  8. fess-crawler/src/main/java/org/codelibs/fess/crawler/client/fs/FileSystemClient.java

            // start
            AccessTimeoutTarget accessTimeoutTarget = null;
            TimeoutTask accessTimeoutTask = null;
            if (accessTimeout != null) {
                accessTimeoutTarget = new AccessTimeoutTarget(Thread.currentThread());
                accessTimeoutTask = TimeoutManager.getInstance().addTimeoutTarget(accessTimeoutTarget, accessTimeout, false);
            }
    
            try {
    Registered: Sat Dec 20 11:21:39 UTC 2025
    - Last Modified: Sun Nov 23 12:19:14 UTC 2025
    - 15.1K bytes
    - Viewed (0)
  9. src/test/java/jcifs/internal/smb2/lease/DirectoryLeaseManagerTest.java

            // Make the cache entry expired
            DirectoryCacheEntry entry = directoryLeaseManager.getCacheEntry(directoryPath);
            entry.setMaxAge(1); // 1ms to expire immediately
            try {
                Thread.sleep(10);
            } catch (InterruptedException e) {
                // Ignore
            }
    
            // When lease is lost, cache entry should be removed
            when(baseLeaseManager.getLease(leaseKey)).thenReturn(null);
    Registered: Sat Dec 20 13:44:44 UTC 2025
    - Last Modified: Sat Aug 23 01:47:47 UTC 2025
    - 15.9K bytes
    - Viewed (0)
  10. guava/src/com/google/common/math/PairedStatsAccumulator.java

    import com.google.common.primitives.Doubles;
    
    /**
     * A mutable object which accumulates paired double values (e.g. points on a plane) and tracks some
     * basic statistics over all the values added so far. This class is not thread safe.
     *
     * @author Pete Gillin
     * @since 20.0
     */
    @J2ktIncompatible
    @GwtIncompatible
    public final class PairedStatsAccumulator {
      /** Creates a new accumulator. */
      public PairedStatsAccumulator() {}
    
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Mon Sep 08 18:35:13 UTC 2025
    - 10.4K bytes
    - Viewed (0)
Back to top