public class Process extends Object
Modifier and Type | Field and Description |
---|---|
static int |
NUM_PROCESSORS |
Constructor and Description |
---|
Process() |
Modifier and Type | Method and Description |
---|---|
static <I,O> void |
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 |
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 |
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 |
progressive(Iterable<I> inputs,
TaskFactory<I,O> generator,
int n_proc) |
static <I,O> void |
unbound(Iterable<I> inputs,
TaskFactory<I,O> generator) |
static <I,O> void |
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 |
unbound(Iterable<I> inputs,
TaskFactory<I,O> generator,
int n_proc) |
public static final <I,O> void progressive(Iterable<I> inputs, TaskFactory<I,O> generator, Collection<O> outputs) throws Exception
Exception
public static final <I,O> void progressive(Iterable<I> inputs, TaskFactory<I,O> generator, Collection<O> outputs, int n_proc) throws Exception
Exception
public static final <I,O> void unbound(Iterable<I> inputs, TaskFactory<I,O> generator, Collection<O> outputs, int n_proc) throws Exception
Exception
public static final <I,O> void progressive(Iterable<I> inputs, TaskFactory<I,O> generator) throws Exception
Exception
public static final <I,O> void progressive(Iterable<I> inputs, TaskFactory<I,O> generator, int n_proc) throws Exception
Exception
public static final <I,O> void unbound(Iterable<I> inputs, TaskFactory<I,O> generator) throws Exception
Exception
public static final <I,O> void unbound(Iterable<I> inputs, TaskFactory<I,O> generator, int n_proc) throws Exception
Exception
Copyright © 2015–2021 Fiji. All rights reserved.