Application.java 2.1 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859
  1. package controllers;
  2. import models.World;
  3. import play.libs.F;
  4. import play.libs.Json;
  5. import static play.libs.Akka.future;
  6. import org.codehaus.jackson.node.ObjectNode;
  7. import org.codehaus.jackson.map.ObjectMapper;
  8. import play.mvc.Controller;
  9. import play.mvc.Result;
  10. import java.util.ArrayList;
  11. import java.util.List;
  12. import java.util.Random;
  13. import java.util.concurrent.Callable;
  14. import java.util.concurrent.ThreadLocalRandom;
  15. import java.util.concurrent.TimeUnit;
  16. public class Application extends Controller {
  17. private static final int TEST_DATABASE_ROWS = 10000;
  18. //http://stackoverflow.com/questions/3907929/should-i-make-jacksons-objectmapper-as-static-final
  19. private static final ObjectMapper objectMapper = new ObjectMapper();
  20. public static Result json() {
  21. final ObjectNode result = objectMapper.createObjectNode();
  22. result.put("message", "Hello World!");
  23. return ok(result);
  24. }
  25. public static Result db(final Integer queries) {
  26. return async(
  27. future(new Callable<Result>() {
  28. @Override
  29. public Result call() {
  30. final Random random = ThreadLocalRandom.current();
  31. final List<F.Promise<? extends World>> promises = new ArrayList<F.Promise<? extends World>>(queries);
  32. for (int i = 0; i < queries; ++i) {
  33. promises.add(future(findWorld(Long.valueOf(random.nextInt(TEST_DATABASE_ROWS) + 1))));
  34. }
  35. final List<World> worlds = F.Promise.sequence(promises).get(5L * queries, TimeUnit.SECONDS);
  36. return ok(Json.toJson(worlds));
  37. }
  38. private Callable<World> findWorld(final Long id) {
  39. return new Callable<World>() {
  40. @Override
  41. public World call() {
  42. return World.find.byId(id);
  43. }
  44. };
  45. }
  46. })
  47. );
  48. }
  49. }