I currently have a pipe which produces Blocks which are folded into a BlockState using Pipes.Prelude.fold.
I have a function which combines two BlockStates into one, and this is relatively quick. The slowest part is converting Blocks into a BlockState. So it seems that a good parallelization strategy would be to convert batches of Blocks into BlockStates in parallel, and merge the resulting BlockStates into the final BlockState. So I need to attach something to the Block pipe which is parallelizable, which takes, say, 100 blocks and converts them into a BlockState. This process can be executed in parallel. The resulting BlockStates can be sent down another pipe which just folds the BlockStates into an empty BlockState. I can't find anything on parallel processing in pipes. How do I enable parallel processing inside a pipe? -- You received this message because you are subscribed to the Google Groups "Haskell Pipes" group. To unsubscribe from this group and stop receiving emails from it, send an email to haskell-pipes+unsubscr...@googlegroups.com. To post to this group, send email to haskell-pipes@googlegroups.com.
