let store = []
worker.on('message', items => {
  store = store.concat(items)
  if (store.length > N) {
    ...someActionWithStore()
    store = []
  }
})

setInterval(() => {
  const items = getItems() // around 200 items per iteration
  parentPort.postMessage(items)
}, 1000)