From d2f40496270bc1d7cda5ad3117598bfcb440fe44 Mon Sep 17 00:00:00 2001 From: dsyer Date: Thu, 6 Mar 2008 08:53:15 +0000 Subject: [PATCH] *SynchronizerSynchronizer was still hanging around --- .../execution/step/ItemOrientedStep.java | 4 +- ...StepExecutionSynchronizerSynchronizer.java | 44 ------------------- 2 files changed, 2 insertions(+), 46 deletions(-) delete mode 100644 spring-batch-execution/src/main/java/org/springframework/batch/execution/step/support/DefaultStepExecutionSynchronizerSynchronizer.java diff --git a/spring-batch-execution/src/main/java/org/springframework/batch/execution/step/ItemOrientedStep.java b/spring-batch-execution/src/main/java/org/springframework/batch/execution/step/ItemOrientedStep.java index 29dc33b47..077f5cb4d 100644 --- a/spring-batch-execution/src/main/java/org/springframework/batch/execution/step/ItemOrientedStep.java +++ b/spring-batch-execution/src/main/java/org/springframework/batch/execution/step/ItemOrientedStep.java @@ -29,7 +29,7 @@ import org.springframework.batch.core.repository.JobRepository; import org.springframework.batch.core.runtime.ExitStatusExceptionClassifier; import org.springframework.batch.core.tasklet.Tasklet; import org.springframework.batch.execution.listener.CompositeStepListener; -import org.springframework.batch.execution.step.support.DefaultStepExecutionSynchronizerSynchronizer; +import org.springframework.batch.execution.step.support.DefaultStepExecutionSynchronizer; import org.springframework.batch.execution.step.support.SimpleExitStatusExceptionClassifier; import org.springframework.batch.execution.step.support.StepExecutionSynchronizer; import org.springframework.batch.execution.step.support.StepInterruptionPolicy; @@ -93,7 +93,7 @@ public class ItemOrientedStep extends AbstractStep { private ItemHandler itemHandler; - private StepExecutionSynchronizer synchronizer = new DefaultStepExecutionSynchronizerSynchronizer(); + private StepExecutionSynchronizer synchronizer = new DefaultStepExecutionSynchronizer(); /** * @param name diff --git a/spring-batch-execution/src/main/java/org/springframework/batch/execution/step/support/DefaultStepExecutionSynchronizerSynchronizer.java b/spring-batch-execution/src/main/java/org/springframework/batch/execution/step/support/DefaultStepExecutionSynchronizerSynchronizer.java deleted file mode 100644 index a087412d1..000000000 --- a/spring-batch-execution/src/main/java/org/springframework/batch/execution/step/support/DefaultStepExecutionSynchronizerSynchronizer.java +++ /dev/null @@ -1,44 +0,0 @@ -/* - * Copyright 2006-2007 the original author or authors. - * - * Licensed under the Apache License, Version 2.0 (the "License"); - * you may not use this file except in compliance with the License. - * You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, software - * distributed under the License is distributed on an "AS IS" BASIS, - * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - * See the License for the specific language governing permissions and - * limitations under the License. - */ -package org.springframework.batch.execution.step.support; - -import org.springframework.batch.core.domain.StepExecution; - -import edu.emory.mathcs.backport.java.util.concurrent.Semaphore; - -/** - * @author Dave Syer - * - */ -public class DefaultStepExecutionSynchronizerSynchronizer implements StepExecutionSynchronizer { - - private Semaphore semaphore = new Semaphore(1); - - /* (non-Javadoc) - * @see org.springframework.batch.execution.step.support.StepExecutionSynchronizer#lock(org.springframework.batch.core.domain.StepExecution) - */ - public void lock(StepExecution stepExecution) throws InterruptedException { - semaphore.acquire(); - } - - /* (non-Javadoc) - * @see org.springframework.batch.execution.step.support.StepExecutionSynchronizer#release(org.springframework.batch.core.domain.StepExecution) - */ - public void release(StepExecution stepExecution) { - semaphore.release(); - } - -}