Search Options

Results per page
Sort
Preferred Languages
Advance

Results 151 - 160 of 725 for reread (0.11 sec)

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

         * approach would be for each caller CAS it from null to a Set populated with its exception. But
         * there's another race: If the first thread fails with an exception and a second thread
         * immediately fails with the same exception:
         *
         * Thread1: calls setException(), which returns true, context switch before it can CAS
         * seenExceptions to its exception
         *
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Tue May 28 20:40:51 UTC 2024
    - 8.4K bytes
    - Viewed (0)
  2. api/maven-api-meta/src/main/java/org/apache/maven/api/annotations/ThreadSafe.java

    import java.lang.annotation.RetentionPolicy;
    import java.lang.annotation.Target;
    
    /**
     * The {@code ThreadSafe} annotation can be used to indicate a given type
     * is thread safe.  {@link Immutable} objects are automatically thread safe.
     *
     * @see Immutable
     * @see NotThreadSafe
     * @since 4.0.0
     */
    @Experimental
    @Documented
    @Retention(RetentionPolicy.CLASS)
    @Target(ElementType.TYPE)
    Registered: Sun Nov 03 03:35:11 UTC 2024
    - Last Modified: Thu Mar 23 05:29:39 UTC 2023
    - 1.4K bytes
    - Viewed (0)
  3. src/test/java/org/codelibs/core/lang/ClassLoaderUtilTest.java

            final ClassLoader context = Thread.currentThread().getContextClassLoader();
            try {
                final ClassLoader cl = new URLClassLoader(new URL[0], getClass().getClassLoader());
                Thread.currentThread().setContextClassLoader(cl);
                assertThat(ClassLoaderUtil.getClassLoader(TestCase.class), is(sameInstance(cl)));
            } finally {
                Thread.currentThread().setContextClassLoader(context);
    Registered: Fri Nov 01 20:58:10 UTC 2024
    - Last Modified: Thu Mar 07 01:59:08 UTC 2024
    - 3K bytes
    - Viewed (0)
  4. okhttp/src/main/kotlin/okhttp3/internal/connection/RoutePlanner.kt

     *
     * It is possible to cancel the finding process by canceling its call.
     *
     * Implementations of this interface are not thread-safe. Each instance is thread-confined to the
     * thread executing the call.
     */
    interface RoutePlanner {
      val address: Address
    
      /** Follow-ups for failed plans and plans that lost a race. */
      val deferredPlans: ArrayDeque<Plan>
    
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Wed Dec 20 23:27:07 UTC 2023
    - 4.2K bytes
    - Viewed (0)
  5. impl/maven-cli/src/main/java/org/apache/maven/cling/invoker/PlexusContainerCapsuleFactory.java

                }
            });
    
            ClassLoader oldCL = Thread.currentThread().getContextClassLoader();
            try {
                container.setLookupRealm(null);
                container.setLoggerManager(createLoggerManager());
                container.getLoggerManager().setThresholds(toPlexusLoggingLevel(context.loggerLevel));
                Thread.currentThread().setContextClassLoader(container.getContainerRealm());
    
    Registered: Sun Nov 03 03:35:11 UTC 2024
    - Last Modified: Fri Oct 25 12:31:46 UTC 2024
    - 13.6K bytes
    - Viewed (0)
  6. tensorflow/c/eager/parallel_device/parallel_device_lib.cc

    //
    // DeviceThread itself is thread-safe, in that StartExecute will block if there
    // is a pending execution. Since StartExecute is equivalent to grabbing a lock,
    // multiple DeviceThreads should always be accessed in the same order to avoid
    // deadlocks.
    class DeviceThread {
     public:
      // Starts a background thread waiting for `StartExecute`.
    Registered: Tue Nov 05 12:39:12 UTC 2024
    - Last Modified: Mon Oct 21 04:14:14 UTC 2024
    - 25.9K bytes
    - Viewed (0)
  7. guava/src/com/google/common/util/concurrent/JdkFutureAdapters.java

    @ElementTypesAreNonnullByDefault
    public final class JdkFutureAdapters {
      /**
       * Assigns a thread to the given {@link Future} to provide {@link ListenableFuture} functionality.
       *
       * <p><b>Warning:</b> If the input future does not already implement {@code ListenableFuture}, the
       * returned future will emulate {@link ListenableFuture#addListener} by taking a thread from an
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Thu Dec 14 20:35:03 UTC 2023
    - 7.5K bytes
    - Viewed (0)
  8. tests/test_tutorial/test_extra_data_types/test_tutorial001_an.py

                                "format": "date-time",
                            },
                            "repeat_at": IsDict(
                                {
                                    "title": "Repeat At",
                                    "anyOf": [
                                        {"type": "string", "format": "time"},
                                        {"type": "null"},
                                    ],
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Fri Apr 19 00:11:40 UTC 2024
    - 6.8K bytes
    - Viewed (0)
  9. docs/em/docs/deployment/manually.md

    <div class="termy">
    
    ```console
    $ hypercorn main:app --bind 0.0.0.0:80
    
    Running on 0.0.0.0:8080 over http (CTRL + C to quit)
    ```
    
    </div>
    
    ////
    
    /// warning
    
    💭 ❎ `--reload` 🎛 🚥 👆 ⚙️ ⚫️.
    
     `--reload` 🎛 🍴 🌅 🌅 ℹ, 🌅 ⚠, ♒️.
    
    ⚫️ ℹ 📚 ⏮️ **🛠️**, ✋️ 👆 **🚫🔜 🚫** ⚙️ ⚫️ **🏭**.
    
    ///
    
    ## Hypercorn ⏮️ 🎻
    
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Tue Aug 06 04:48:30 UTC 2024
    - 4.2K bytes
    - Viewed (0)
  10. okhttp/src/main/kotlin/okhttp3/internal/cache2/Relay.kt

        /** The next byte to read. This is always less than or equal to [upstreamPos]. */
        private var sourcePos = 0L
    
        /**
         * Selects where to find the bytes for a read and read them. This is one of three sources.
         *
         * ## Upstream
         *
         * In this case the current thread is assigned as the upstream reader. We read bytes from
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 11.8K bytes
    - Viewed (0)
Back to top