Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1011 - 1020 of 2,167 for Batch (0.09 sec)

  1. android/guava/src/com/google/common/collect/Serialization.java

        void set(T instance, Object value) {
          try {
            field.set(instance, value);
          } catch (IllegalAccessException impossible) {
            throw new AssertionError(impossible);
          }
        }
    
        void set(T instance, int value) {
          try {
            field.set(instance, value);
          } catch (IllegalAccessException impossible) {
            throw new AssertionError(impossible);
          }
        }
      }
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Mon Mar 06 16:06:58 UTC 2023
    - 8.5K bytes
    - Viewed (0)
  2. fess-crawler-opensearch/src/main/java/org/codelibs/fess/crawler/service/impl/OpenSearchUrlQueueService.java

        @PreDestroy
        public void destroy() {
            sessionCache.entrySet().stream().map(e -> e.getValue().waitingQueue).forEach(q -> q.forEach(urlQueue -> {
                try {
                    insert(urlQueue);
                } catch (final Exception e) {
                    logger.warn("Failed to restore " + urlQueue, e);
                }
            }));
        }
    
        public void clearCache() {
            sessionCache.clear();
        }
    
        @Override
    Registered: Sun Nov 10 03:50:12 UTC 2024
    - Last Modified: Thu Nov 07 04:44:10 UTC 2024
    - 13.4K bytes
    - Viewed (0)
  3. docs_src/response_model/tutorial003_04_py310.py

    app = FastAPI()
    
    
    @app.get("/portal")
    async def get_portal(teleport: bool = False) -> Response | dict:
        if teleport:
            return RedirectResponse(url="https://www.youtube.com/watch?v=dQw4w9WgXcQ")
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Tue Jan 10 16:22:47 UTC 2023
    - 352 bytes
    - Viewed (0)
  4. docs/en/docs/reference/apirouter.md

            members:
                - websocket
                - include_router
                - get
                - put
                - post
                - delete
                - options
                - head
                - patch
                - trace
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Thu Apr 18 19:53:19 UTC 2024
    - 524 bytes
    - Viewed (0)
  5. common-protos/k8s.io/api/apps/v1beta2/generated.proto

      // +optional
      optional int32 minReadySeconds = 4;
    
      // Selector is a label query over pods that should match the replica count.
      // Label keys and values that must match in order to be controlled by this replica set.
      // It must match the pod template's labels.
      // More info: https://kubernetes.io/docs/concepts/overview/working-with-objects/labels/#label-selectors
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Mon Mar 11 18:43:24 UTC 2024
    - 36.4K bytes
    - Viewed (0)
  6. src/main/java/org/codelibs/fess/helper/PathMappingHelper.java

                    });
                }
                return cachedPathMappingList.size();
            } catch (final ComponentNotFoundException e) {
                if (logger.isDebugEnabled()) {
                    logger.debug("Failed to load path mappings.", e);
                }
                cachedPathMappingList = new ArrayList<>();
            } catch (final Exception e) {
                logger.warn("Failed to load path mappings.", e);
            }
    Registered: Thu Oct 31 13:40:30 UTC 2024
    - Last Modified: Thu Feb 22 01:53:18 UTC 2024
    - 7.6K bytes
    - Viewed (0)
  7. guava-tests/test/com/google/common/cache/CacheReferencesTest.java

          if (cache.size() == 1) {
            break;
          }
          try {
            Thread.sleep(10);
          } catch (InterruptedException e) {
            /* ignore */
          }
          try {
            // Fill up heap so soft references get cleared.
            filler = new byte[max(filler.length, filler.length * 2)];
          } catch (OutOfMemoryError e) {
          }
        }
    
        CacheTesting.processPendingNotifications(cache);
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Mon Oct 21 14:28:19 UTC 2024
    - 6.2K bytes
    - Viewed (0)
  8. src/main/java/jcifs/smb1/ntlmssp/Type1Message.java

            DEFAULT_DOMAIN = Config.getProperty("jcifs.smb1.smb.client.domain", null);
            String defaultWorkstation = null;
            try {
                defaultWorkstation = NbtAddress.getLocalHost().getHostName();
            } catch (UnknownHostException ex) { }
            DEFAULT_WORKSTATION = defaultWorkstation;
        }
    
        /**
         * Creates a Type-1 message using default values from the current
         * environment.
         */
    Registered: Sun Nov 03 00:10:13 UTC 2024
    - Last Modified: Fri Mar 22 20:39:42 UTC 2019
    - 8K bytes
    - Viewed (0)
  9. guava-tests/test/com/google/common/util/concurrent/TrustedListenableFutureTaskTest.java

                    enterLatch.countDown();
                    try {
                      new CountDownLatch(1).await(); // wait forever
                      throw new AssertionError();
                    } catch (InterruptedException e) {
                      interruptedExceptionThrown.set(true);
                      throw e;
                    } finally {
                    }
                  }
                });
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Mon Oct 21 15:41:36 UTC 2024
    - 7.3K bytes
    - Viewed (0)
  10. docs_src/response_model/tutorial003_02.py

    app = FastAPI()
    
    
    @app.get("/portal")
    async def get_portal(teleport: bool = False) -> Response:
        if teleport:
            return RedirectResponse(url="https://www.youtube.com/watch?v=dQw4w9WgXcQ")
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Tue Jan 10 16:22:47 UTC 2023
    - 381 bytes
    - Viewed (0)
Back to top