Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 66 for blockedOn (0.21 sec)

  1. android/guava/src/com/google/common/util/concurrent/InterruptibleTask.java

             * interrupting thread. In theory, interruptTask() should be very fast, but due to
             * InterruptibleChannel and JavaLangAccess.blockedOn(Thread, Interruptible), it isn't
             * predictable what work might be done. (e.g., close a file and flush buffers to disk). To
             * protect ourselves from this, we park ourselves and tell our interrupter that we did so.
    Java
    - Registered: Fri Apr 26 12:43:10 GMT 2024
    - Last Modified: Fri Sep 29 21:34:48 GMT 2023
    - 9.9K bytes
    - Viewed (0)
  2. maven-core/src/main/java/org/apache/maven/artifact/repository/MavenArtifactRepository.java

            } else {
                this.mirroredRepositories = Collections.emptyList();
            }
        }
    
        public boolean isBlocked() {
            return blocked;
        }
    
        public void setBlocked(boolean blocked) {
            this.blocked = blocked;
        }
    Java
    - Registered: Sun May 05 03:35:11 GMT 2024
    - Last Modified: Mon Dec 26 15:12:32 GMT 2022
    - 11K bytes
    - Viewed (0)
  3. maven-artifact/src/main/java/org/apache/maven/artifact/repository/ArtifactRepository.java

        @Deprecated
        void setBlacklisted(boolean blackListed);
    
        /**
         * @return whether the repository is blocked
         * @since 3.8.1
         **/
        boolean isBlocked();
    
        /**
         * @param blocked block the repository?
         * @since 3.8.1
         **/
        void setBlocked(boolean blocked);
    
        //
        // New interface methods for the repository system.
        //
        /**
         *
    Java
    - Registered: Sun May 05 03:35:11 GMT 2024
    - Last Modified: Thu Feb 23 17:14:45 GMT 2023
    - 4.2K bytes
    - Viewed (0)
  4. maven-compat/src/main/java/org/apache/maven/artifact/repository/DefaultArtifactRepository.java

            } else {
                this.mirroredRepositories = Collections.emptyList();
            }
        }
    
        public boolean isBlocked() {
            return blocked;
        }
    
        public void setBlocked(boolean blocked) {
            this.blocked = blocked;
        }
    Java
    - Registered: Sun May 05 03:35:11 GMT 2024
    - Last Modified: Wed Sep 06 08:39:32 GMT 2023
    - 7.3K bytes
    - Viewed (0)
  5. maven-core/src/test/java/org/apache/maven/internal/MultilineMessageHelperTest.java

            msgs.add("* but aggregator Mojos require exclusive access to reactor to   *");
            msgs.add("* prevent race conditions. This mojo execution will be blocked  *");
            msgs.add("* until the aggregator work is done.                            *");
            msgs.add("*****************************************************************");
    
            assertEquals(
                    msgs,
    Java
    - Registered: Sun Apr 28 03:35:10 GMT 2024
    - Last Modified: Sat Apr 15 17:24:20 GMT 2023
    - 3.5K bytes
    - Viewed (0)
  6. android/guava-tests/test/com/google/common/util/concurrent/InterruptibleTaskTest.java

        // 1. the runner has been woken up
        // 2. the interrupter is stuck in the call the Thread.interrupt()
    
        // after some period of time the runner thread should become blocked on the task because it is
        // waiting for the slow interrupting thread to complete Thread.interrupt
        awaitBlockedOnInstanceOf(runner, InterruptibleTask.Blocker.class);
    
    Java
    - Registered: Fri May 03 12:43:13 GMT 2024
    - Last Modified: Wed Sep 06 17:04:31 GMT 2023
    - 6.6K bytes
    - Viewed (0)
  7. android/guava-tests/test/com/google/common/util/concurrent/GeneratedMonitorTest.java

      private static final long SMALL_TIMEOUT_MILLIS = 10;
    
      /** How long to wait when determining that a thread is blocked if we expect it to be blocked. */
      private static final long EXPECTED_HANG_DELAY_MILLIS = 75;
    
      /**
       * How long to wait when determining that a thread is blocked if we DON'T expect it to be blocked.
       */
      private static final long UNEXPECTED_HANG_DELAY_MILLIS = 10000;
    
      /**
    Java
    - Registered: Fri May 03 12:43:13 GMT 2024
    - Last Modified: Mon Apr 17 14:48:57 GMT 2023
    - 26.1K bytes
    - Viewed (0)
  8. guava-tests/test/com/google/common/util/concurrent/GeneratedMonitorTest.java

      private static final long SMALL_TIMEOUT_MILLIS = 10;
    
      /** How long to wait when determining that a thread is blocked if we expect it to be blocked. */
      private static final long EXPECTED_HANG_DELAY_MILLIS = 75;
    
      /**
       * How long to wait when determining that a thread is blocked if we DON'T expect it to be blocked.
       */
      private static final long UNEXPECTED_HANG_DELAY_MILLIS = 10000;
    
      /**
    Java
    - Registered: Fri Apr 12 12:43:09 GMT 2024
    - Last Modified: Mon Apr 17 14:48:57 GMT 2023
    - 27.4K bytes
    - Viewed (0)
  9. android/guava-tests/test/com/google/common/util/concurrent/SequentialExecutorTest.java

                throw new RejectedExecutionException();
              }
            };
        final SequentialExecutor executor = new SequentialExecutor(delegate);
        final ExecutorService blocked = Executors.newCachedThreadPool();
        Future<?> first =
            blocked.submit(
                new Runnable() {
                  @Override
                  public void run() {
                    executor.execute(Runnables.doNothing());
                  }
    Java
    - Registered: Fri May 03 12:43:13 GMT 2024
    - Last Modified: Wed Sep 06 17:04:31 GMT 2023
    - 11.4K bytes
    - Viewed (0)
  10. guava-tests/test/com/google/common/util/concurrent/InterruptibleTaskTest.java

        // 1. the runner has been woken up
        // 2. the interrupter is stuck in the call the Thread.interrupt()
    
        // after some period of time the runner thread should become blocked on the task because it is
        // waiting for the slow interrupting thread to complete Thread.interrupt
        awaitBlockedOnInstanceOf(runner, InterruptibleTask.Blocker.class);
    
    Java
    - Registered: Fri Apr 12 12:43:09 GMT 2024
    - Last Modified: Wed Sep 06 17:04:31 GMT 2023
    - 6.6K bytes
    - Viewed (0)
Back to top