@@ -199,7 +199,11 @@ public abstract class AbstractTaskletStepBuilder<B extends AbstractTaskletStepBu
|
|||||||
* in the job repository for this step.
|
* in the job repository for this step.
|
||||||
* @param throttleLimit maximum number of concurrent tasklet executions allowed
|
* @param throttleLimit maximum number of concurrent tasklet executions allowed
|
||||||
* @return this for fluent chaining
|
* @return this for fluent chaining
|
||||||
|
* @deprecated since 5.0, scheduled for removal in 6.0. Use a pooled
|
||||||
|
* {@link TaskExecutor} implemenation with a limited capacity of its task queue
|
||||||
|
* instead.
|
||||||
*/
|
*/
|
||||||
|
@Deprecated(since = "5.0", forRemoval = true)
|
||||||
public B throttleLimit(int throttleLimit) {
|
public B throttleLimit(int throttleLimit) {
|
||||||
this.throttleLimit = throttleLimit;
|
this.throttleLimit = throttleLimit;
|
||||||
return self();
|
return self();
|
||||||
@@ -280,6 +284,7 @@ public abstract class AbstractTaskletStepBuilder<B extends AbstractTaskletStepBu
|
|||||||
return taskExecutor;
|
return taskExecutor;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@Deprecated(since = "5.0", forRemoval = true)
|
||||||
protected int getThrottleLimit() {
|
protected int getThrottleLimit() {
|
||||||
return throttleLimit;
|
return throttleLimit;
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -1,5 +1,5 @@
|
|||||||
/*
|
/*
|
||||||
* Copyright 2006-2007 the original author or authors.
|
* Copyright 2006-2022 the original author or authors.
|
||||||
*
|
*
|
||||||
* Licensed under the Apache License, Version 2.0 (the "License");
|
* Licensed under the Apache License, Version 2.0 (the "License");
|
||||||
* you may not use this file except in compliance with the License.
|
* you may not use this file except in compliance with the License.
|
||||||
@@ -43,6 +43,7 @@ import org.springframework.util.Assert;
|
|||||||
* any given time, and each thread would have its own transaction).<br>
|
* any given time, and each thread would have its own transaction).<br>
|
||||||
*
|
*
|
||||||
* @author Dave Syer
|
* @author Dave Syer
|
||||||
|
* @author Mahmoud Ben Hassine
|
||||||
*
|
*
|
||||||
*/
|
*/
|
||||||
public class TaskExecutorRepeatTemplate extends RepeatTemplate {
|
public class TaskExecutorRepeatTemplate extends RepeatTemplate {
|
||||||
@@ -68,7 +69,11 @@ public class TaskExecutorRepeatTemplate extends RepeatTemplate {
|
|||||||
* being reached (so make the core pool size larger than the throttle limit if
|
* being reached (so make the core pool size larger than the throttle limit if
|
||||||
* possible).
|
* possible).
|
||||||
* @param throttleLimit the throttleLimit to set.
|
* @param throttleLimit the throttleLimit to set.
|
||||||
|
* @deprecated since 5.0, scheduled for removal in 6.0. Use a pooled
|
||||||
|
* {@link TaskExecutor} implemenation with a limited capacity of its task queue
|
||||||
|
* instead.
|
||||||
*/
|
*/
|
||||||
|
@Deprecated(since = "5.0", forRemoval = true)
|
||||||
public void setThrottleLimit(int throttleLimit) {
|
public void setThrottleLimit(int throttleLimit) {
|
||||||
this.throttleLimit = throttleLimit;
|
this.throttleLimit = throttleLimit;
|
||||||
}
|
}
|
||||||
|
|||||||
Reference in New Issue
Block a user