- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 77 for Lock (0.13 sec)
-
android/guava-tests/test/com/google/common/util/concurrent/StripedTest.java
.add(new Striped.SmallLazyStriped<ReadWriteLock>(50, READ_WRITE_LOCK_SUPPLIER)) .add(new Striped.SmallLazyStriped<ReadWriteLock>(64, READ_WRITE_LOCK_SUPPLIER)) .add(new Striped.LargeLazyStriped<ReadWriteLock>(50, READ_WRITE_LOCK_SUPPLIER)) .add(new Striped.LargeLazyStriped<ReadWriteLock>(64, READ_WRITE_LOCK_SUPPLIER)) .add(new Striped.SmallLazyStriped<Lock>(50, LOCK_SUPPLER))
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Wed Feb 09 22:57:07 GMT 2022 - 8.4K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/ForwardingLock.java
import java.util.concurrent.locks.Condition; import java.util.concurrent.locks.Lock; /** Forwarding wrapper around a {@code Lock}. */ @J2ktIncompatible @ElementTypesAreNonnullByDefault abstract class ForwardingLock implements Lock { abstract Lock delegate(); @Override public void lock() { delegate().lock(); } @Override public void lockInterruptibly() throws InterruptedException {
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Tue Apr 04 09:45:04 GMT 2023 - 1.5K bytes - Viewed (0) -
guava-tests/benchmark/com/google/common/util/concurrent/CycleDetectingLockFactoryBenchmark.java
} @Benchmark void unorderedCycleDetectingLocks(int reps) { lockAndUnlock(factory.newReentrantLock("foo"), reps); } private static void lockAndUnlock(Lock lock, int reps) { for (int i = 0; i < reps; i++) { lock.lock(); lock.unlock(); } } @Benchmark void orderedPlainLocks(int reps) { lockAndUnlockNested(plainLocks, reps); } @Benchmark
Java - Registered: Fri Apr 19 12:43:09 GMT 2024 - Last Modified: Mon Dec 04 17:37:03 GMT 2017 - 2.4K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/StripedTest.java
.add(new Striped.SmallLazyStriped<ReadWriteLock>(50, READ_WRITE_LOCK_SUPPLIER)) .add(new Striped.SmallLazyStriped<ReadWriteLock>(64, READ_WRITE_LOCK_SUPPLIER)) .add(new Striped.LargeLazyStriped<ReadWriteLock>(50, READ_WRITE_LOCK_SUPPLIER)) .add(new Striped.LargeLazyStriped<ReadWriteLock>(64, READ_WRITE_LOCK_SUPPLIER)) .add(new Striped.SmallLazyStriped<Lock>(50, LOCK_SUPPLER))
Java - Registered: Fri Apr 12 12:43:09 GMT 2024 - Last Modified: Wed Feb 09 22:57:07 GMT 2022 - 8.4K bytes - Viewed (0) -
android/guava-tests/benchmark/com/google/common/util/concurrent/CycleDetectingLockFactoryBenchmark.java
} @Benchmark void unorderedCycleDetectingLocks(int reps) { lockAndUnlock(factory.newReentrantLock("foo"), reps); } private static void lockAndUnlock(Lock lock, int reps) { for (int i = 0; i < reps; i++) { lock.lock(); lock.unlock(); } } @Benchmark void orderedPlainLocks(int reps) { lockAndUnlockNested(plainLocks, reps); } @Benchmark
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Mon Dec 04 17:37:03 GMT 2017 - 2.4K bytes - Viewed (0) -
src/main/java/jcifs/smb1/smb1/TransactNamedPipeInputStream.java
private boolean dcePipe; Object lock; TransactNamedPipeInputStream( SmbNamedPipe pipe ) throws SmbException, MalformedURLException, UnknownHostException { super( pipe, ( pipe.pipeType & 0xFFFF00FF ) | SmbFile.O_EXCL ); this.dcePipe = ( pipe.pipeType & SmbNamedPipe.PIPE_TYPE_DCE_TRANSACT ) != SmbNamedPipe.PIPE_TYPE_DCE_TRANSACT; lock = new Object(); }
Java - Registered: Sun May 05 00:10:10 GMT 2024 - Last Modified: Fri Mar 22 21:10:40 GMT 2019 - 4.6K bytes - Viewed (0) -
src/main/java/jcifs/internal/smb2/lock/Smb2LockResponse.java
* License along with this library; if not, write to the Free Software * Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA */ package jcifs.internal.smb2.lock; import jcifs.Configuration; import jcifs.internal.SMBProtocolDecodingException; import jcifs.internal.smb2.ServerMessageBlock2Response; import jcifs.internal.util.SMBUtil; /** * @author mbechler
Java - Registered: Sun May 05 00:10:10 GMT 2024 - Last Modified: Sun Jul 01 13:12:10 GMT 2018 - 1.9K bytes - Viewed (0) -
src/main/java/jcifs/smb1/smb1/TransCallNamedPipeResponse.java
if( pipe.pipeIn != null ) { TransactNamedPipeInputStream in = (TransactNamedPipeInputStream)pipe.pipeIn; synchronized( in.lock ) { in.receive( buffer, bufferIndex, len ); in.lock.notify(); } } return len; } public String toString() { return new String( "TransCallNamedPipeResponse[" + super.toString() + "]" );
Java - Registered: Sun May 05 00:10:10 GMT 2024 - Last Modified: Fri Mar 22 21:10:40 GMT 2019 - 2K bytes - Viewed (0) -
src/main/java/jcifs/smb1/smb1/TransTransactNamedPipeResponse.java
if( pipe.pipeIn != null ) { TransactNamedPipeInputStream in = (TransactNamedPipeInputStream)pipe.pipeIn; synchronized( in.lock ) { in.receive( buffer, bufferIndex, len ); in.lock.notify(); } } return len; } public String toString() {
Java - Registered: Sun May 05 00:10:10 GMT 2024 - Last Modified: Fri Mar 22 21:10:40 GMT 2019 - 2K bytes - Viewed (0) -
src/main/java/jcifs/internal/smb2/lock/Smb2Lock.java
*/ package jcifs.internal.smb2.lock; import jcifs.Encodable; import jcifs.internal.util.SMBUtil; /** * @author mbechler * */ public class Smb2Lock implements Encodable { /** * */ public static final int SMB2_LOCKFLAG_SHARED_LOCK = 0x1; /** * */ public static final int SMB2_LOCKFLAG_EXCLUSIVE_LOCK = 0x2; /** * */
Java - Registered: Sun May 05 00:10:10 GMT 2024 - Last Modified: Sun Jul 01 13:12:10 GMT 2018 - 2.2K bytes - Viewed (0)