gridSize
specifies the number of data blocks
to create to be processed by (usually) the same number of workers
. Think about it as a number of mapped data blocks in a map/reduce.
Using a StepExecutionSplitter
, given the data, PartitionHandler
"partitions" / splits the data to a gridSize
parts, and sends each part to an independent worker => thread
in your case.
For example, you have 10 rows in DB that need to be processed. If you set the gridSize
to be 5, and you are using a straightforward partition logic, you'd end up with 10 / 5 = 2 rows per thread => 5 threads working concurrently on 2 rows each.
与恶龙缠斗过久,自身亦成为恶龙;凝视深渊过久,深渊将回以凝视…