| Package | Description |
|---|---|
| ini.trakem2.parallel |
| Modifier and Type | Class and Description |
|---|---|
class |
CountingTaskFactory<I,O> |
| Modifier and Type | Method and Description |
|---|---|
static <I,O> void |
Process.progressive(Iterable<I> inputs,
TaskFactory<I,O> generator)
Takes a Collection of inputs, applies a function to each created by the generator.
|
static <I,O> void |
Process.progressive(Iterable<I> inputs,
TaskFactory<I,O> generator,
Collection<O> outputs)
Takes a Collection of inputs, applies a function to each created by the generator,
and places their output in outputs in the same order as each input was retrieved from inputs.
|
static <I,O> void |
Process.progressive(Iterable<I> inputs,
TaskFactory<I,O> generator,
Collection<O> outputs,
int n_proc)
Takes a Collection of inputs, applies a function to each created by the generator,
and places their output in outputs in the same order as each input was retrieved from inputs.
|
static <I,O> void |
Process.progressive(Iterable<I> inputs,
TaskFactory<I,O> generator,
int n_proc) |
static <I,O> void |
Process.unbound(Iterable<I> inputs,
TaskFactory<I,O> generator) |
static <I,O> void |
Process.unbound(Iterable<I> inputs,
TaskFactory<I,O> generator,
Collection<O> outputs,
int n_proc)
Takes a Collection of inputs, applies a function to each created by the generator,
and places their output in outputs in the same order as each input was retrieved from inputs;
will not wait for executing tasks to finish before creating and submitting new tasks.
|
static <I,O> void |
Process.unbound(Iterable<I> inputs,
TaskFactory<I,O> generator,
int n_proc) |
| Constructor and Description |
|---|
ParallelMapping(int n_proc,
Iterable<I> inputs,
TaskFactory<I,O> generator) |
ParallelMapping(int n_proc,
Iterator<I> inputs,
TaskFactory<I,O> generator) |
ParallelMapping(Iterable<I> inputs,
TaskFactory<I,O> generator) |
ParallelMapping(Iterator<I> inputs,
TaskFactory<I,O> generator) |
Copyright © 2015–2021 Fiji. All rights reserved.