taskscheduling.java

public class SomeUtilityClass {
  private static final ThreadPoolExecutor threads = new ThreadPoolExecutor(
				Runtime.getRuntime().availableProcessors(), 10,
				10, TimeUnit.SECONDS, new ArrayBlockingQueue<Runnable>(100, true));

	public static void scheduleTask(Runnable runnable) {
		threads.execute(runnable);
	}
}


//inputsystem
	@Override
	protected void processEntities(ImmutableBag<Entity> entities) {
		if (useThreads) GDXGame.getInstance().scheduleTask(new InputTask(entities));
		else new InputTask(entities).run();
	}

	public class InputTask implements Runnable {
		private final ImmutableBag<Entity> entities;
		public InputTask(ImmutableBag<Entity> entities) {
			this.entities = entities;
		}

		@Override
		public void run() {
			for (int i = 0; i < entities.size(); i++) update(entities.get(i));
		}

		private void update(Entity e) {
			InputC input = inputMapper.get(e);
			if (input.controlling == Controlling.NotControlled) return;
			if (input.controlling == Controlling.Controlling) {
				input.keys = gdx.game.logic.Input.keys;
				input.camDir = CameraHelper.getDirection();
			}
			input.process(e);
		}
	}