Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 130 for Task (0.04 sec)

  1. src/main/java/org/codelibs/fess/thumbnail/impl/CommandGenerator.java

                logger.warn("Failed to generate a thumbnail of {}: {}", thumbnailId, commandList, e);
            }
            if (task != null && !task.isExecuted()) {
                task.cancel();
            }
        }
    
        protected static class ProcessDestroyer extends TimerTask {
    
            private final Process p;
    
            private final InputStreamThread ist;
    
            private final AtomicBoolean executed = new AtomicBoolean(false);
    Registered: Thu Oct 31 13:40:30 UTC 2024
    - Last Modified: Fri Oct 11 21:20:39 UTC 2024
    - 9.6K bytes
    - Viewed (0)
  2. cmd/bucket-lifecycle.go

    							task.event.StorageClass, task.objInfo.Bucket, task.objInfo.Name, task.objInfo.VersionID, err))
    					}
    				}
    			} else {
    				ts := tierStats{
    					TotalSize:   uint64(task.objInfo.Size),
    					NumVersions: 1,
    				}
    				if task.objInfo.IsLatest {
    					ts.NumObjects = 1
    				}
    				t.addLastDayStats(task.event.StorageClass, ts)
    			}
    			t.activeTasks.Add(-1)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Oct 23 15:35:37 UTC 2024
    - 33.7K bytes
    - Viewed (0)
  3. docs/en/docs/tutorial/background-tasks.md

    ## Create a task function
    
    Create a function to be run as the background task.
    
    It is just a standard function that can receive parameters.
    
    It can be an `async def` or normal `def` function, **FastAPI** will know how to handle it correctly.
    
    In this case, the task function will write to a file (simulating sending an email).
    
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Sun Oct 27 15:22:48 UTC 2024
    - 4.8K bytes
    - Viewed (0)
  4. tensorflow/c/eager/c_api_distributed_test.cc

      EXPECT_EQ(TF_GetCode(status), TF_OK) << TF_Message(status);
    
      const char task0_name[] = "/job:localhost/replica:0/task:0/device:CPU:0";
      const char task1_name[] = "/job:localhost/replica:0/task:1/device:CPU:0";
      const char task2_name[] = "/job:localhost/replica:0/task:2/device:CPU:0";
    
      // Create one variable per task.
      TFE_TensorHandle* h0 = TestVariable(ctx, 1.0, task1_name);
      TFE_TensorHandle* h1 = TestVariable(ctx, 2.0, task2_name);
    Registered: Tue Nov 05 12:39:12 UTC 2024
    - Last Modified: Sat Oct 12 05:11:17 UTC 2024
    - 23.4K bytes
    - Viewed (0)
  5. guava-tests/test/com/google/common/util/concurrent/ExecutionSequencerTest.java

                directExecutor());
    
        // Wait for the first task to be started in the background. It will block until we explicitly
        // stop it.
        blockingCallable.waitForStart();
    
        // Give the second task a chance to (incorrectly) start up while the first task is running.
        assertThat(future2.isDone()).isFalse();
    
        // Stop the first task. The second task should then run.
        blockingCallable.stop();
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 18 22:10:29 UTC 2024
    - 16.7K bytes
    - Viewed (0)
  6. 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());
    
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 18 22:10:29 UTC 2024
    - 4.7K bytes
    - Viewed (0)
  7. 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());
    
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 18 22:10:29 UTC 2024
    - 4.7K bytes
    - Viewed (0)
  8. 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));
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Mon Oct 21 15:41:36 UTC 2024
    - 7.3K bytes
    - Viewed (0)
  9. build-logic/binary-compatibility/src/test/kotlin/gradlebuild/binarycompatibility/UpgradedPropertiesChangesTest.kt

                    "Method com.example.Task.getIsFailOnError(): Is not annotated with @Incubating. Reason for accepting this: Upgraded property" to listOf("Method added to public class"),
                    "Method com.example.Task.getIsFailOnError(): Is not annotated with @since 2.0. Reason for accepting this: Upgraded property" to listOf("Method added to public class"),
    Registered: Wed Nov 06 11:36:14 UTC 2024
    - Last Modified: Wed Oct 02 14:20:08 UTC 2024
    - 26.1K bytes
    - Viewed (0)
  10. src/main/java/org/codelibs/fess/thumbnail/ThumbnailManager.java

                    final Tuple3<String, String, String> task = generator.createTask(path, docMap);
                    if (task != null) {
                        if (logger.isDebugEnabled()) {
                            logger.debug("Add thumbnail task: {}", task);
                        }
                        if (!thumbnailTaskQueue.offer(task)) {
                            logger.warn("Failed to add thumbnail task: {}", task);
                        }
    Registered: Thu Oct 31 13:40:30 UTC 2024
    - Last Modified: Fri Oct 11 21:20:39 UTC 2024
    - 21.5K bytes
    - Viewed (0)
Back to top