- Sort Score
- Result 10 results
- Languages All
Results 171 - 180 of 478 for Durrant (0.03 sec)
-
guava/src/com/google/common/util/concurrent/ExecutionSequencer.java
* thread. */ private static final class ThreadConfinedTaskQueue { /** * This field is only used for identity comparisons with the current thread. Field assignments * are atomic, but do not provide happens-before ordering; however: * * <ul> * <li>If this field's value == currentThread, we know that it's up to date, because writeRegistered: Fri Dec 26 12:43:10 UTC 2025 - Last Modified: Tue Sep 23 01:35:55 UTC 2025 - 22.1K bytes - Viewed (0) -
guava-tests/benchmark/com/google/common/util/concurrent/MonitorBasedArrayBlockingQueue.java
return (++i == items.length) ? 0 : i; } /** * Inserts element at current put position, advances, and signals. Call only when occupying * monitor. */ private void insert(E x) { items[putIndex] = x; putIndex = inc(putIndex); ++count; } /** * Extracts element at current take position, advances, and signals. Call only when occupying * monitor. */
Registered: Fri Dec 26 12:43:10 UTC 2025 - Last Modified: Tue May 13 18:46:00 UTC 2025 - 22.4K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/helper/CrawlerStatsHelper.java
log(buf); } }); } /** * Gets the current system time in milliseconds. * * @return current time in milliseconds */ protected long getCurrentTimeMillis() { return ComponentUtil.getSystemHelper().getCurrentTimeAsLong(); } /**
Registered: Sat Dec 20 09:19:18 UTC 2025 - Last Modified: Thu Aug 07 03:06:29 UTC 2025 - 17.4K bytes - Viewed (0) -
src/main/java/jcifs/internal/smb1/com/SmbComSeek.java
import jcifs.internal.SMBProtocolDecodingException; import jcifs.internal.smb1.ServerMessageBlock; import jcifs.internal.util.SMBUtil; /** * SMB1 COM_SEEK command implementation. * * This command changes the current file position pointer for a file. * It allows seeking to different positions within an open file. * * @author mbechler */ public class SmbComSeek extends ServerMessageBlock { /**Registered: Sat Dec 20 13:44:44 UTC 2025 - Last Modified: Sat Aug 16 01:32:48 UTC 2025 - 3.4K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/app/web/admin/accesstoken/CreateForm.java
public Long createdTime; /** * Initializes the form with default values for creation. * Sets the CRUD mode to CREATE and populates created by and created time fields * with current user and timestamp information. */ public void initialize() { crudMode = CrudMode.CREATE; createdBy = ComponentUtil.getSystemHelper().getUsername();Registered: Sat Dec 20 09:19:18 UTC 2025 - Last Modified: Thu Jul 17 08:28:31 UTC 2025 - 3.4K bytes - Viewed (0) -
src/main/java/org/codelibs/core/sql/DriverManagerUtil.java
} catch (final SQLException e) { throw new SQLRuntimeException(e); } } /** * Deregisters all JDBC drivers associated with the current class loader. */ public static synchronized void deregisterAllDrivers() { for (final Enumeration<Driver> e = DriverManager.getDrivers(); e.hasMoreElements();) { deregisterDriver(e.nextElement());
Registered: Sat Dec 20 08:55:33 UTC 2025 - Last Modified: Thu Jul 31 08:16:49 UTC 2025 - 3.2K bytes - Viewed (0) -
android/guava/src/com/google/common/collect/ObjectCountHashMap.java
@Nullable Object[] keys = this.keys; int[] values = this.values; int hash = smearedHash(key); int tableIndex = hash & hashTableMask(); int newEntryIndex = this.size; // current size, and pointer to the entry to be appended int next = table[tableIndex]; if (next == UNSET) { table[tableIndex] = newEntryIndex; } else { int last; long entry; do {
Registered: Fri Dec 26 12:43:10 UTC 2025 - Last Modified: Sat Aug 09 01:14:59 UTC 2025 - 14.5K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/app/web/admin/general/AdminGeneralAction.java
if (StringUtil.isNotBlank(form.logLevel)) { systemHelper.setLogLevel(form.logLevel); } } /** * Updates the form with current configuration values. * * @param fessConfig the current Fess configuration * @param form the form to populate with configuration values */ public static void updateForm(final FessConfig fessConfig, final EditForm form) {Registered: Sat Dec 20 09:19:18 UTC 2025 - Last Modified: Sat Dec 13 02:21:17 UTC 2025 - 14.4K bytes - Viewed (0) -
src/main/java/jcifs/smb/PreauthIntegrityService.java
} } return isValid; } /** * Gets the current preauth hash for a session. * * @param sessionId the session identifier * @return the current hash, or null if no context exists */ public byte[] getCurrentPreauthHash(String sessionId) {Registered: Sat Dec 20 13:44:44 UTC 2025 - Last Modified: Sun Aug 31 08:00:57 UTC 2025 - 12.1K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/InterruptionUtil.java
if (shouldStop) { break; } interruptee.interrupt(); } } void stopInterrupting() { shouldStop = true; } } /** Interrupts the current thread after sleeping for the specified delay. */ static void requestInterruptIn(long time, TimeUnit unit) { checkNotNull(unit); Thread interruptee = Thread.currentThread(); new Thread(
Registered: Fri Dec 26 12:43:10 UTC 2025 - Last Modified: Sun Aug 10 19:54:19 UTC 2025 - 4.5K bytes - Viewed (0)