Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 1081 - 1090 of 1,335 for concurrent (0.06 seconds)

  1. src/main/java/jcifs/dcerpc/DcerpcHandle.java

     * Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA  02111-1307  USA
     */
    
    package jcifs.dcerpc;
    
    import java.io.IOException;
    import java.net.MalformedURLException;
    import java.util.concurrent.atomic.AtomicInteger;
    
    import jcifs.CIFSContext;
    import jcifs.CIFSException;
    import jcifs.dcerpc.ndr.NdrBuffer;
    import jcifs.dcerpc.ndr.NdrException;
    
    /**
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Sat Aug 16 01:32:48 GMT 2025
    - 15.9K bytes
    - Click Count (0)
  2. src/test/java/jcifs/smb/SmbTransportImplTest.java

    import static org.mockito.Mockito.times;
    import static org.mockito.Mockito.verify;
    import static org.mockito.Mockito.when;
    
    import java.lang.reflect.Field;
    import java.net.Socket;
    import java.util.concurrent.atomic.AtomicLong;
    
    import org.junit.jupiter.api.BeforeEach;
    import org.junit.jupiter.api.DisplayName;
    import org.junit.jupiter.api.Nested;
    import org.junit.jupiter.api.Test;
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Thu Aug 14 05:31:44 GMT 2025
    - 17.6K bytes
    - Click Count (0)
  3. src/main/java/org/codelibs/fess/app/web/admin/elevateword/AdminElevatewordAction.java

    import java.util.stream.Collectors;
    import java.util.stream.Stream;
    
    import org.apache.logging.log4j.LogManager;
    import org.apache.logging.log4j.Logger;
    import org.codelibs.core.beans.util.BeanUtil;
    import org.codelibs.core.concurrent.CommonPoolUtil;
    import org.codelibs.core.lang.StringUtil;
    import org.codelibs.fess.Constants;
    import org.codelibs.fess.annotation.Secured;
    import org.codelibs.fess.app.pager.ElevateWordPager;
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Fri Jan 23 23:57:26 GMT 2026
    - 22.2K bytes
    - Click Count (0)
  4. src/main/java/org/codelibs/curl/CurlRequest.java

    import java.io.UnsupportedEncodingException;
    import java.net.HttpURLConnection;
    import java.net.Proxy;
    import java.net.URL;
    import java.net.URLEncoder;
    import java.util.ArrayList;
    import java.util.List;
    import java.util.concurrent.ForkJoinPool;
    import java.util.function.BiConsumer;
    import java.util.function.Consumer;
    import java.util.function.Supplier;
    import java.util.logging.Logger;
    import java.util.zip.GZIPInputStream;
    
    Created: Thu Apr 02 15:34:12 GMT 2026
    - Last Modified: Sat Mar 21 09:11:12 GMT 2026
    - 19.7K bytes
    - Click Count (0)
  5. guava/src/com/google/common/collect/CollectSpliterators.java

            backingCharacteristics &=
                Spliterator.SIZED
                    | Spliterator.SUBSIZED
                    | Spliterator.ORDERED
                    | Spliterator.IMMUTABLE
                    | Spliterator.CONCURRENT;
            return characteristics | backingCharacteristics;
          }
        };
      }
    
      /** Returns a {@code Spliterator} filtered by the specified predicate. */
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Nov 17 22:50:48 GMT 2025
    - 19.9K bytes
    - Click Count (0)
  6. android/guava-testlib/src/com/google/common/collect/testing/testers/ListSubListTester.java

    import com.google.common.collect.testing.features.ListFeature;
    import com.google.common.testing.SerializableTester;
    import java.lang.reflect.Method;
    import java.util.List;
    import java.util.concurrent.CopyOnWriteArrayList;
    import org.junit.Ignore;
    
    /**
     * A generic JUnit test which tests {@code subList()} operations on a list. Can't be invoked
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Thu Aug 07 16:05:33 GMT 2025
    - 13.5K bytes
    - Click Count (0)
  7. guava-testlib/src/com/google/common/collect/testing/testers/ListSubListTester.java

    import com.google.common.collect.testing.features.ListFeature;
    import com.google.common.testing.SerializableTester;
    import java.lang.reflect.Method;
    import java.util.List;
    import java.util.concurrent.CopyOnWriteArrayList;
    import org.junit.Ignore;
    
    /**
     * A generic JUnit test which tests {@code subList()} operations on a list. Can't be invoked
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Thu Aug 07 16:05:33 GMT 2025
    - 13.5K bytes
    - Click Count (0)
  8. mockwebserver/src/main/kotlin/mockwebserver3/MockResponse.kt

     */
    @file:Suppress(
      "CANNOT_OVERRIDE_INVISIBLE_MEMBER",
      "INVISIBLE_MEMBER",
      "INVISIBLE_REFERENCE",
      "ktlint:standard:property-naming",
    )
    
    package mockwebserver3
    
    import java.util.concurrent.TimeUnit
    import mockwebserver3.SocketEffect.CloseStream
    import mockwebserver3.internal.toMockResponseBody
    import okhttp3.Headers
    import okhttp3.Headers.Companion.headersOf
    import okhttp3.WebSocketListener
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Fri Jun 20 11:46:46 GMT 2025
    - 17.8K bytes
    - Click Count (0)
  9. cmd/xl-storage.go

    	sync.RWMutex
    	formatData []byte
    
    	nrRequests   uint64
    	major, minor uint32
    	fsType       string
    
    	immediatePurge       chan string
    	immediatePurgeCancel context.CancelFunc
    
    	// mutex to prevent concurrent read operations overloading walks.
    	rotational bool
    	walkMu     *sync.Mutex
    	walkReadMu *sync.Mutex
    }
    
    // checkPathLength - returns error if given path name length more than 255
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 91.7K bytes
    - Click Count (0)
  10. src/test/java/org/codelibs/fess/ds/callback/IndexUpdateCallbackImplTest.java

     */
    package org.codelibs.fess.ds.callback;
    
    import java.util.ArrayList;
    import java.util.HashMap;
    import java.util.HashSet;
    import java.util.List;
    import java.util.Map;
    import java.util.Set;
    import java.util.concurrent.atomic.AtomicInteger;
    
    import org.codelibs.fess.entity.DataStoreParams;
    import org.codelibs.fess.exception.DataStoreException;
    import org.codelibs.fess.helper.CrawlingInfoHelper;
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Fri Mar 13 23:01:26 GMT 2026
    - 24.7K bytes
    - Click Count (0)
Back to Top