Search Options

Results per page
Sort
Preferred Languages
Advance

Results 81 - 90 of 361 for Mask (0.24 sec)

  1. guava-tests/test/com/google/common/util/concurrent/ListenableFutureTaskTest.java

        assertFalse(task.isDone());
        assertFalse(task.isCancelled());
    
        // Start the task to put it in the RUNNING state.  Have to use a separate
        // thread because the task will block on the task latch after unblocking
        // the run latch.
        exec.execute(task);
        runLatch.await();
        assertEquals(1, listenerLatch.getCount());
        assertFalse(task.isDone());
        assertFalse(task.isCancelled());
    
    Java
    - Registered: Fri Apr 12 12:43:09 GMT 2024
    - Last Modified: Wed Sep 06 17:04:31 GMT 2023
    - 4.7K bytes
    - Viewed (0)
  2. doc/go1.17_spec.html

    Four * 100   // product 400 cannot be represented as an int8 (type of Four)
    </pre>
    
    <p>
    The mask used by the unary bitwise complement operator <code>^</code> matches
    the rule for non-constants: the mask is all 1s for unsigned constants
    and -1 for signed and untyped constants.
    </p>
    
    <pre>
    ^1         // untyped integer constant, equal to -2
    HTML
    - Registered: Tue May 07 11:14:38 GMT 2024
    - Last Modified: Thu Apr 11 20:22:45 GMT 2024
    - 211.6K bytes
    - Viewed (0)
  3. guava-tests/test/com/google/common/util/concurrent/TrustedListenableFutureTaskTest.java

        TrustedListenableFutureTask<Integer> task = TrustedListenableFutureTask.create(returning(2));
        assertFalse(task.isDone());
        task.run();
        assertTrue(task.isDone());
        assertFalse(task.isCancelled());
        assertEquals(2, getDone(task).intValue());
      }
    
      public void testCancelled() throws Exception {
        TrustedListenableFutureTask<Integer> task = TrustedListenableFutureTask.create(returning(2));
    Java
    - Registered: Fri Apr 12 12:43:09 GMT 2024
    - Last Modified: Tue Feb 13 14:28:25 GMT 2024
    - 7.3K bytes
    - Viewed (0)
  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. cmd/background-heal-ops.go

    				}
    			}
    
    			if bgSeq != nil {
    				// We increment relevant counter based on the heal result for prometheus reporting.
    				if err != nil {
    					bgSeq.countFailed(res)
    				} else {
    					bgSeq.countHeals(res.Type, false)
    				}
    			}
    
    			if task.respCh != nil {
    				task.respCh <- healResult{result: res, err: err}
    			}
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 4.6K bytes
    - Viewed (0)
  9. android/guava-tests/test/com/google/common/util/concurrent/ListenableFutureTaskTest.java

        assertFalse(task.isDone());
        assertFalse(task.isCancelled());
    
        // Start the task to put it in the RUNNING state.  Have to use a separate
        // thread because the task will block on the task latch after unblocking
        // the run latch.
        exec.execute(task);
        runLatch.await();
        assertEquals(1, listenerLatch.getCount());
        assertFalse(task.isDone());
        assertFalse(task.isCancelled());
    
    Java
    - Registered: Fri May 03 12:43:13 GMT 2024
    - Last Modified: Wed Sep 06 17:04:31 GMT 2023
    - 4.7K bytes
    - Viewed (0)
  10. okhttp/src/main/kotlin/okhttp3/internal/concurrent/TaskLogger.kt

    import java.util.logging.Level
    import java.util.logging.Logger
    
    internal inline fun Logger.taskLog(
      task: Task,
      queue: TaskQueue,
      messageBlock: () -> String,
    ) {
      if (isLoggable(Level.FINE)) {
        log(task, queue, messageBlock())
      }
    }
    
    internal inline fun <T> Logger.logElapsed(
      task: Task,
      queue: TaskQueue,
      block: () -> T,
    ): T {
      var startNs = -1L
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Mon Jan 08 01:13:22 GMT 2024
    - 2.6K bytes
    - Viewed (0)
Back to top