Browse Source

Polishing

(cherry picked from commit abbea39855)
pull/30971/head
Juergen Hoeller 2 years ago
parent
commit
c5aa7830bc
  1. 10
      spring-context/src/main/java/org/springframework/scheduling/annotation/SchedulingConfigurer.java
  2. 24
      spring-core/src/main/java/org/springframework/core/task/SimpleAsyncTaskExecutor.java
  3. 7
      spring-core/src/main/java/org/springframework/util/ConcurrencyThrottleSupport.java

10
spring-context/src/main/java/org/springframework/scheduling/annotation/SchedulingConfigurer.java

@ -1,5 +1,5 @@
/* /*
* Copyright 2002-2021 the original author or authors. * Copyright 2002-2023 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.
@ -40,10 +40,10 @@ import org.springframework.scheduling.config.ScheduledTaskRegistrar;
public interface SchedulingConfigurer { public interface SchedulingConfigurer {
/** /**
* Callback allowing a {@link org.springframework.scheduling.TaskScheduler * Callback allowing a {@link org.springframework.scheduling.TaskScheduler}
* TaskScheduler} and specific {@link org.springframework.scheduling.config.Task Task} * and specific {@link org.springframework.scheduling.config.Task} instances
* instances to be registered against the given the {@link ScheduledTaskRegistrar}. * to be registered against the given the {@link ScheduledTaskRegistrar}.
* @param taskRegistrar the registrar to be configured. * @param taskRegistrar the registrar to be configured
*/ */
void configureTasks(ScheduledTaskRegistrar taskRegistrar); void configureTasks(ScheduledTaskRegistrar taskRegistrar);

24
spring-core/src/main/java/org/springframework/core/task/SimpleAsyncTaskExecutor.java

@ -1,5 +1,5 @@
/* /*
* Copyright 2002-2022 the original author or authors. * Copyright 2002-2023 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.
@ -33,8 +33,8 @@ import org.springframework.util.concurrent.ListenableFutureTask;
* {@link TaskExecutor} implementation that fires up a new Thread for each task, * {@link TaskExecutor} implementation that fires up a new Thread for each task,
* executing it asynchronously. * executing it asynchronously.
* *
* <p>Supports limiting concurrent threads through the "concurrencyLimit" * <p>Supports limiting concurrent threads through {@link #setConcurrencyLimit}.
* bean property. By default, the number of concurrent threads is unlimited. * By default, the number of concurrent task executions is unlimited.
* *
* <p><b>NOTE: This implementation does not reuse threads!</b> Consider a * <p><b>NOTE: This implementation does not reuse threads!</b> Consider a
* thread-pooling TaskExecutor implementation instead, in particular for * thread-pooling TaskExecutor implementation instead, in particular for
@ -133,33 +133,31 @@ public class SimpleAsyncTaskExecutor extends CustomizableThreadCreator
* have to cast it and call {@code Future#get} to evaluate exceptions. * have to cast it and call {@code Future#get} to evaluate exceptions.
* @since 4.3 * @since 4.3
*/ */
public final void setTaskDecorator(TaskDecorator taskDecorator) { public void setTaskDecorator(TaskDecorator taskDecorator) {
this.taskDecorator = taskDecorator; this.taskDecorator = taskDecorator;
} }
/** /**
* Set the maximum number of parallel accesses allowed. * Set the maximum number of parallel task executions allowed.
* -1 indicates no concurrency limit at all. * The default of -1 indicates no concurrency limit at all.
* <p>In principle, this limit can be changed at runtime, * <p>This is the equivalent of a maximum pool size in a thread pool,
* although it is generally designed as a config time setting. * preventing temporary overload of the thread management system.
* NOTE: Do not switch between -1 and any concrete limit at runtime,
* as this will lead to inconsistent concurrency counts: A limit
* of -1 effectively turns off concurrency counting completely.
* @see #UNBOUNDED_CONCURRENCY * @see #UNBOUNDED_CONCURRENCY
* @see org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor#setMaxPoolSize
*/ */
public void setConcurrencyLimit(int concurrencyLimit) { public void setConcurrencyLimit(int concurrencyLimit) {
this.concurrencyThrottle.setConcurrencyLimit(concurrencyLimit); this.concurrencyThrottle.setConcurrencyLimit(concurrencyLimit);
} }
/** /**
* Return the maximum number of parallel accesses allowed. * Return the maximum number of parallel task executions allowed.
*/ */
public final int getConcurrencyLimit() { public final int getConcurrencyLimit() {
return this.concurrencyThrottle.getConcurrencyLimit(); return this.concurrencyThrottle.getConcurrencyLimit();
} }
/** /**
* Return whether this throttle is currently active. * Return whether the concurrency throttle is currently active.
* @return {@code true} if the concurrency limit for this instance is active * @return {@code true} if the concurrency limit for this instance is active
* @see #getConcurrencyLimit() * @see #getConcurrencyLimit()
* @see #setConcurrencyLimit * @see #setConcurrencyLimit

7
spring-core/src/main/java/org/springframework/util/ConcurrencyThrottleSupport.java

@ -1,5 +1,5 @@
/* /*
* Copyright 2002-2018 the original author or authors. * Copyright 2002-2023 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.
@ -69,7 +69,7 @@ public abstract class ConcurrencyThrottleSupport implements Serializable {
/** /**
* Set the maximum number of concurrent access attempts allowed. * Set the maximum number of concurrent access attempts allowed.
* -1 indicates unbounded concurrency. * The default of -1 indicates no concurrency limit at all.
* <p>In principle, this limit can be changed at runtime, * <p>In principle, this limit can be changed at runtime,
* although it is generally designed as a config time setting. * although it is generally designed as a config time setting.
* <p>NOTE: Do not switch between -1 and any concrete limit at runtime, * <p>NOTE: Do not switch between -1 and any concrete limit at runtime,
@ -143,9 +143,10 @@ public abstract class ConcurrencyThrottleSupport implements Serializable {
*/ */
protected void afterAccess() { protected void afterAccess() {
if (this.concurrencyLimit >= 0) { if (this.concurrencyLimit >= 0) {
boolean debug = logger.isDebugEnabled();
synchronized (this.monitor) { synchronized (this.monitor) {
this.concurrencyCount--; this.concurrencyCount--;
if (logger.isDebugEnabled()) { if (debug) {
logger.debug("Returning from throttle at concurrency count " + this.concurrencyCount); logger.debug("Returning from throttle at concurrency count " + this.concurrencyCount);
} }
this.monitor.notify(); this.monitor.notify();

Loading…
Cancel
Save