This repository was archived by the owner on Jul 19, 2025. It is now read-only.

Commit 8883adc

committed

Use thread-safe fixnum for processed files count

1 parent 433c117 commit 8883adcCopy full SHA for 8883adc

File tree

-3

lines changed

-3

lines changed

Lines changed: 3 additions & 3 deletions

Original file line number	Diff line number	Diff line change
`@@ -30,20 +30,20 @@ def process_files`
`30`	`30`	`concurrency: engine_config.concurrency`
`31`	`31`	`)`
`32`	`32`
`33`		`- processed_files_count = 0`
	`33`	`+ processed_files_count = Concurrent::AtomicFixnum.new`
`34`	`34`
`35`	`35`	`pool.run do \|file\|`
`36`	`36`	`debug("Processing file: #{file}")`
`37`	`37`
`38`	`38`	`sexp = language_strategy.run(file)`
`39`	`39`	`process_sexp(sexp)`
`40`	`40`
`41`		`- processed_files_count += 1`
	`41`	`+ processed_files_count.increment`
`42`	`42`	`end`
`43`	`43`
`44`	`44`	`pool.join`
`45`	`45`
`46`		`- debug("Processed #{processed_files_count} files")`
	`46`	`+ debug("Processed #{processed_files_count.value} files")`
`47`	`47`	`end`
`48`	`48`
`49`	`49`	`def report`

Comments

(0)