- Sort Score
- Num 10 results
- Language All
Results 1081 - 1090 of 1,335 for concurrent (0.07 seconds)
-
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) -
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) -
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) -
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) -
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) -
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 invokedCreated: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Thu Aug 07 16:05:33 GMT 2025 - 13.5K bytes - Click Count (0) -
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 invokedCreated: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Thu Aug 07 16:05:33 GMT 2025 - 13.5K bytes - Click Count (0) -
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) -
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) -
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)