Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 4 of 4 for currentTask (0.04 sec)

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

        override fun start() {
          taskRunner.assertLockHeld()
          require(currentTask == this)
          activeThreads++
    
          tasksExecutor.execute {
            taskRunner.assertLockNotHeld()
            require(currentTask == this)
            try {
              runnable.run()
              require(currentTask == this) { "unexpected current task: $currentTask" }
            } finally {
              taskRunner.withLock {
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Wed May 28 23:28:25 UTC 2025
    - 11.9K bytes
    - Viewed (0)
  2. guava-tests/test/com/google/common/util/concurrent/SequentialExecutorTest.java

      }
    
      public void testToString() {
        Runnable[] currentTask = new Runnable[1];
        Executor delegate =
            new Executor() {
              @Override
              public void execute(Runnable task) {
                currentTask[0] = task;
                task.run();
                currentTask[0] = null;
              }
    
              @Override
              public String toString() {
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Fri Jul 11 18:52:30 UTC 2025
    - 11.4K bytes
    - Viewed (0)
  3. src/main/java/jcifs/smb/PreauthIntegrityService.java

            public byte[] getCurrentHash() {
                synchronized (hashLock) {
                    return currentHash.clone();
                }
            }
    
            public void updateHash(byte[] newHash) {
                synchronized (hashLock) {
                    if (newHash != null && newHash.length == currentHash.length) {
                        this.currentHash = newHash.clone();
                    }
                }
            }
    
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Sun Aug 31 08:00:57 UTC 2025
    - 12.1K bytes
    - Viewed (0)
  4. cmd/erasure-sets.go

    				s.erasureDisksMu.Unlock()
    				return
    			}
    
    			if currentDisk := s.erasureDisks[setIndex][diskIndex]; currentDisk != nil {
    				if !reflect.DeepEqual(currentDisk.Endpoint(), disk.Endpoint()) {
    					err = fmt.Errorf("Detected unexpected drive ordering refusing to use the drive: expecting %s, found %s, refusing to use the drive",
    						currentDisk.Endpoint(), disk.Endpoint())
    					printEndpointError(endpoint, err, false)
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 37K bytes
    - Viewed (1)
Back to top