change the parallelMapListToChan function, always use Queryable.chunkSize as the size of chunk. If the size of chunk are not same after special operation (e.g. where, join, distinct), it can balance the load of each CPU core.