Spring/spring-integration
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Using an AtomicInteger for incrementAndGet.

Browse Source
This commit is contained in:
Mark Fisher
2007-12-21 22:19:12 +00:00
parent 3ad89f1074
commit 58836bcc50
1 changed files with 4 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
spring-integration-samples/src/main/java/org/springframework/integration/samples/oddeven/Counter.java
View File

@@ -16,6 +16,8 @@
package org.springframework.integration.samples.oddeven;
import java.util.concurrent.atomic.AtomicInteger;
import org.springframework.integration.endpoint.annotation.MessageEndpoint;
import org.springframework.integration.endpoint.annotation.Polled;
import org.springframework.integration.handler.annotation.Router;
@@ -26,11 +28,11 @@ import org.springframework.integration.handler.annotation.Router;
@MessageEndpoint
public class Counter {
private volatile int count = 1;
private AtomicInteger count = new AtomicInteger();
@Polled(period=3000)
public int getNumber() {
return count++;
return count.incrementAndGet();
}
@Router