Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 159 for Rask (0.16 sec)

  1. okhttp-testing-support/src/main/kotlin/okhttp3/internal/concurrent/TaskFaker.kt

      var nanoTime = 0L
        private set
    
      /** Backlog of tasks to run. Only one task runs at a time. Guarded by [TaskRunner.lock]. */
      private val serialTaskQueue = ArrayDeque<SerialTask>()
    
      /** The task that's currently executing. Guarded by [TaskRunner.lock]. */
      private var currentTask: SerialTask = TestThreadSerialTask
    
      /** The coordinator task if it's waiting, and how it will resume. Guarded by [TaskRunner.lock]. */
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Mon Apr 29 00:33:04 GMT 2024
    - 12.6K bytes
    - Viewed (0)
  2. CONTRIBUTING.md

    3. Make sure the file with accepted changes is sorted.\
    Use the `./gradlew :architecture-test:sortAcceptedApiChanges` task to sort the file.
    
    4. Validate your changes before committing.\
    Run the `./gradlew sanityCheck` task again to make sure there are no more errors.
    
    #### Filtering changes by severity
    
    Plain Text
    - Registered: Wed May 01 11:36:15 GMT 2024
    - Last Modified: Fri Feb 09 15:30:53 GMT 2024
    - 15.6K bytes
    - Viewed (0)
  3. android/guava/src/com/google/common/util/concurrent/Striped.java

        final int mask;
    
        PowerOfTwoStriped(int stripes) {
          Preconditions.checkArgument(stripes > 0, "Stripes must be positive");
          this.mask = stripes > Ints.MAX_POWER_OF_TWO ? ALL_SET : ceilToPowerOfTwo(stripes) - 1;
        }
    
        @Override
        final int indexFor(Object key) {
          int hash = smear(key.hashCode());
          return hash & mask;
        }
    
        @Override
    Java
    - Registered: Fri Apr 26 12:43:10 GMT 2024
    - Last Modified: Mon Apr 10 20:55:18 GMT 2023
    - 20.3K bytes
    - Viewed (1)
  4. build-logic/binary-compatibility/src/test/kotlin/gradlebuild/binarycompatibility/UpgradedPropertiesChangesTest.kt

                assertHasErrors("Method com.example.Task.getFailOnError(): Is not annotated with @since 2.0.")
                assertHasAccepted(
                    "Method com.example.Task.getFailOnError(): Is not annotated with @Incubating. Reason for accepting this: Upgraded property" to listOf("Method added to public class", "Abstract method has been added to this class"),
    Plain Text
    - Registered: Wed May 01 11:36:15 GMT 2024
    - Last Modified: Tue Apr 23 08:40:36 GMT 2024
    - 20.2K bytes
    - Viewed (0)
  5. okhttp/src/test/java/okhttp3/internal/concurrent/TaskRunnerTest.kt

          "FINE: Q10000 scheduled after 100 µs: task",
          "FINE: Q10000 starting              : task",
          "FINE: Q10000 run again after  50 µs: task",
          "FINE: Q10000 finished run in   0 µs: task",
          "FINE: Q10000 starting              : task",
          "FINE: Q10000 run again after 150 µs: task",
          "FINE: Q10000 finished run in   0 µs: task",
          "FINE: Q10000 starting              : task",
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Mon Apr 29 00:33:04 GMT 2024
    - 23K bytes
    - Viewed (0)
  6. build-logic/documentation/src/main/groovy/gradlebuild/docs/GradleUserManualPlugin.java

            tasks.withType(AsciidoctorTask.class).configureEach(task -> {
                if (task.getName().equals("asciidoctor")) {
                    // ignore this task
                    task.setEnabled(false);
                    return;
                }
    
                task.setExecutionMode(ExecutionMode.OUT_OF_PROCESS);
                task.outputOptions(options -> {
                    options.setSeparateOutputDirs(false);
    Java
    - Registered: Wed May 01 11:36:15 GMT 2024
    - Last Modified: Fri Mar 01 05:46:51 GMT 2024
    - 17.7K bytes
    - Viewed (0)
  7. android/guava/src/com/google/common/util/concurrent/SequentialExecutor.java

                    hasSetRunning = true;
                  }
                }
                task = queue.poll();
                if (task == null) {
                  workerRunningState = IDLE;
                  return;
                }
              }
              // Remove the interrupt bit before each task. The interrupt is for the "current task" when
              // it is sent, so subsequent tasks in the queue should not be caused to be interrupted
    Java
    - Registered: Fri Apr 26 12:43:10 GMT 2024
    - Last Modified: Thu Feb 01 21:46:34 GMT 2024
    - 10.6K bytes
    - Viewed (0)
  8. guava/src/com/google/common/collect/CompactHashSet.java

        int hash = smearedHash(object);
        int mask = hashTableMask();
        int tableIndex = hash & mask;
        int next = CompactHashing.tableGet(requireTable(), tableIndex);
        if (next == UNSET) { // uninitialized bucket
          if (newSize > mask) {
            // Resize and add new entry
            mask = resizeTable(mask, CompactHashing.newCapacity(mask), hash, newEntryIndex);
          } else {
    Java
    - Registered: Fri Apr 05 12:43:09 GMT 2024
    - Last Modified: Mon Feb 05 21:38:59 GMT 2024
    - 24.9K bytes
    - Viewed (0)
  9. android/guava/src/com/google/common/util/concurrent/ExecutionSequencer.java

           *   user task -- which means that we already got past this code (or else we exited early
           *   above))
           */
          // Unconditionally set; there is no risk of throwing away a queued task from another thread,
          // because in order for the current task to run on this executor the previous task must have
          // already started execution. Because each task on a TaskNonReentrantExecutor can only produce
    Java
    - Registered: Fri Apr 26 12:43:10 GMT 2024
    - Last Modified: Thu Feb 01 21:46:34 GMT 2024
    - 22.1K bytes
    - Viewed (0)
  10. guava-tests/test/com/google/common/util/concurrent/SequentialExecutorTest.java

                  }
                });
        Runnable task =
            new Runnable() {
              @Override
              public void run() {
                numCalls.incrementAndGet();
              }
            };
        assertThrows(RejectedExecutionException.class, () -> executor.execute(task));
        assertEquals(0, numCalls.get());
        reject.set(false);
        executor.execute(task);
        assertEquals(1, numCalls.get());
      }
    
    Java
    - Registered: Fri Apr 12 12:43:09 GMT 2024
    - Last Modified: Wed Sep 06 17:04:31 GMT 2023
    - 11.4K bytes
    - Viewed (0)
Back to top