Convolution: add implementations of the deprecated setExecuter method

Author: maarzt

src/main/java/net/imglib2/algorithm/convolution/Concatenation.java

@@ -31,6 +31,14 @@ class Concatenation< T > implements Convolution< T >
 		this.steps = new ArrayList<>( steps );
 	}
 
+	@Deprecated
+	@Override
+	public void setExecutor( ExecutorService executor )
+	{
+		for ( Convolution<T> step : steps )
+			step.setExecutor( executor );
+	}
+
 	@Override
 	public Interval requiredSourceInterval( final Interval targetInterval )
 	{

src/main/java/net/imglib2/algorithm/convolution/LineConvolution.java

@@ -7,10 +7,15 @@
 import net.imglib2.RandomAccessible;
 import net.imglib2.RandomAccessibleInterval;
 import net.imglib2.loops.LoopBuilder;
+import net.imglib2.parallel.Parallelization;
+import net.imglib2.parallel.TaskExecutor;
+import net.imglib2.parallel.TaskExecutors;
 import net.imglib2.util.Intervals;
 import net.imglib2.util.Localizables;
 import net.imglib2.view.Views;
 
+import java.util.concurrent.ExecutorService;
+
 /**
  * This class can be used to implement a separable convolution. It applies a
  * {@link LineConvolverFactory} on the given images.
@@ -23,12 +28,21 @@ public class LineConvolution< T > implements Convolution<T>
 
 	private final int direction;
 
+	private ExecutorService executor;
+
 	public LineConvolution( final LineConvolverFactory< ? super T > factory, final int direction )
 	{
 		this.factory = factory;
 		this.direction = direction;
 	}
 
+	@Deprecated
+	@Override
+	public void setExecutor( ExecutorService executor )
+	{
+		this.executor = executor;
+	}
+
 	@Override
 	public Interval requiredSourceInterval( final Interval targetInterval )
 	{
@@ -56,7 +70,8 @@ public void process( RandomAccessible< ? extends T > source, RandomAccessibleInt
 		dim[ direction ] = 1;
 
 		RandomAccessibleInterval< Localizable > positions = Localizables.randomAccessibleInterval( new FinalInterval( dim ) );
-		LoopBuilder.setImages( positions ).multiThreaded().forEachChunk(
+		TaskExecutor taskExecutor = executor == null ? Parallelization.getTaskExecutor() : TaskExecutors.forExecutorService( executor );
+		LoopBuilder.setImages( positions ).multiThreaded(taskExecutor).forEachChunk(
 				chunk -> {
 
 					final RandomAccess< ? extends T > in = sourceInterval.randomAccess();

src/main/java/net/imglib2/algorithm/convolution/MultiDimensionConvolution.java

@@ -20,6 +20,7 @@ public class MultiDimensionConvolution< T > implements Convolution< T >
 {
 	private ExecutorService executor;
 
+	@Deprecated
 	@Override
 	public void setExecutor( final ExecutorService executor )
 	{