threads = []
		gather_thread = Thread(target = self.gather_data, args = (in_slices))
		gather_thread.start()
		threads.append(gather_thread)
		gather.thread.join()

		for t in threads
		    t.join()


		task.run()

		threads = []
		scatter_thread = Thread(target = self.scatter_data, args = (out_slices))
		scatter_thread.start()
		threads.append(scatter_thread)

		for t in threads
		    t.join()