support multi-thread training on each worker