Commitd3dda84

committed

Cosmetics

1 parent01dfc04 commitd3dda84Copy full SHA for d3dda84

File tree

-6

lines changed

src/com/winterbe/java8/samples/concurrent
- Atomic1.java
- LongAccumulator1.java

-6

lines changed

Lines changed: 1 addition & 1 deletion

Original file line number	Diff line number	Diff line change
`@@ -11,7 +11,7 @@`
`11`	`11`	`*/`
`12`	`12`	`publicclassAtomic1 {`
`13`	`13`
`14`		`-privatestaticfinalintNUM_INCREMENTS =10000;`
	`14`	`+privatestaticfinalintNUM_INCREMENTS =1000;`
`15`	`15`
`16`	`16`	`privatestaticAtomicIntegeratomicInt =newAtomicInteger(0);`
`17`	`17`

Lines changed: 5 additions & 5 deletions

Original file line number	Diff line number	Diff line change
`@@ -3,25 +3,25 @@`
`3`	`3`	`importjava.util.concurrent.ExecutorService;`
`4`	`4`	`importjava.util.concurrent.Executors;`
`5`	`5`	`importjava.util.concurrent.atomic.LongAccumulator;`
	`6`	`+importjava.util.function.LongBinaryOperator;`
`6`	`7`	`importjava.util.stream.IntStream;`
`7`	`8`
`8`	`9`	`/**`
`9`	`10`	`* @author Benjamin Winterberg`
`10`	`11`	`*/`
`11`	`12`	`publicclassLongAccumulator1 {`
`12`	`13`
`13`		`-privatestaticfinalintSIZE =10;`
`14`		`-`
`15`		`-privatestaticLongAccumulatoraccumulator =newLongAccumulator((x,y) ->2 *x +y,1L);`
`16`		`-`
`17`	`14`	`publicstaticvoidmain(String[]args) {`
`18`	`15`	`testAccumulate();`
`19`	`16`	`}`
`20`	`17`
`21`	`18`	`privatestaticvoidtestAccumulate() {`
	`19`	`+LongBinaryOperatorop = (x,y) ->2 *x +y;`
	`20`	`+LongAccumulatoraccumulator =newLongAccumulator(op,1L);`
	`21`	`+`
`22`	`22`	`ExecutorServiceexecutor =Executors.newFixedThreadPool(2);`
`23`	`23`
`24`		`-IntStream.range(0,SIZE)`
	`24`	`+IntStream.range(0,10)`
`25`	`25`	`.forEach(i ->executor.submit(() ->accumulator.accumulate(i)));`
`26`	`26`
`27`	`27`	`ConcurrentUtils.stop(executor);`

Comments

(0)