- Sort Score
- Result 10 results
- Languages All
Results 1 - 5 of 5 for readTask (0.6 sec)
-
platforms/core-configuration/core-serialization-codecs/src/main/kotlin/org/gradle/internal/serialize/codecs/core/TaskNodeCodec.kt
override suspend fun WriteContext.encode(value: LocalTaskNode) { val task = value.task writeTask(task) } override suspend fun ReadContext.decode(): LocalTaskNode { val task = readTask() val node = taskNodeFactory.getOrCreateNode(task) as LocalTaskNode node.isolated() return node } private suspend fun WriteContext.writeTask(task: TaskInternal) {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Sat Jun 08 11:29:30 UTC 2024 - 17.2K bytes - Viewed (0) -
src/runtime/rwmutex.go
// represent internal ranking. Semantic ranking is represented by a separate // acquire of readRank for the duration of a read lock. // // The lock ranking must document this ordering: // - readRankInternal is a leaf lock. // - readRank is taken before readRankInternal. // - writeRank is taken before readRankInternal. // - readRank is placed in the lock order wherever a read lock of this rwmutex // belongs.
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Apr 22 14:29:04 UTC 2024 - 5K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/concurrent/TaskRunner.kt
readyTask != null -> { beforeRun(readyTask) // Also start another thread if there's more work or scheduling to do. if (multipleReadyTasks || !coordinatorWaiting && readyQueues.isNotEmpty()) { startAnotherThread() } return readyTask } // Notify the coordinator of a task that's coming up soon.
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Mon Apr 29 00:33:04 UTC 2024 - 10.6K bytes - Viewed (0) -
src/main/java/jcifs/pac/kerberos/KerberosEncData.java
break; case 5: // Kerberos Time // DERGeneralizedTime derTime = KerberosUtil.readAs(tagged, // DERGeneralizedTime.class); break; case 6: // Kerberos Time // DERGeneralizedTime derTime = KerberosUtil.readAs(tagged, // DERGeneralizedTime.class); break; case 7: // Kerberos Time
Registered: Wed Jun 12 15:45:55 UTC 2024 - Last Modified: Mon Oct 02 12:02:06 UTC 2023 - 11.4K bytes - Viewed (0) -
internal/ringbuffer/ring_buffer_test.go
} if readHash.Sum32() != wroteHash.Sum32() { t.Fatalf("expect read hash 0x%08x but got 0x%08x", readHash.Sum32(), wroteHash.Sum32()) } } func TestRingBuffer_BlockingBig(t *testing.T) { // Typical runtime is ~5-10s. defer timeout(60 * time.Second)() const debug = false var readBytes int var wroteBytes int readHash := crc32.NewIEEE() wroteHash := crc32.NewIEEE()
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Wed May 15 00:11:04 UTC 2024 - 26.8K bytes - Viewed (0)