1. import java.util.ArrayList;
  2. import java.util.List;
  3. import java.util.concurrent.ExecutorService;
  4. import java.util.concurrent.Executors;
  5. import java.util.concurrent.TimeUnit;
  6. import java.util.concurrent.TimeoutException;
  8. class Entry {
  9. private String id;
  10. private String data;
  12. public Entry(String id, String data) {
  13. this.id = id;
  14. this.data = data;
  15. }
  17. public String getId() {
  18. return id;
  19. }
  21. public String getData() {
  22. return data;
  23. }
  24. }
  26. public class NestedEntries {
  28. public static List<Entry> fetchNestedEntries(int maxEntries, long timeoutMillis) throws TimeoutException {
  29. List<Entry> allEntries = new ArrayList<>();
  30. ExecutorService executor = Executors.newFixedThreadPool(10); // Adjust thread pool size as needed
  32. for (int i = 0; i < maxEntries; i++) {
  33. final int entryId = i; // Capture i for the lambda expression
  34. executor.submit(() -> {
  35. try {
  36. // Simulate an asynchronous operation with a potential delay
  37. Thread.sleep((long) (Math.random() * 1000)); // Simulate work
  38. String data = "Data for entry " + entryId;
  39. allEntries.add(new Entry("entry-" + entryId, data));
  40. } catch (InterruptedException e) {
  41. Thread.currentThread().interrupt();
  42. }
  43. });
  44. }
  46. executor.shutdown();
  47. try {
  48. if (!executor.awaitTermination(timeoutMillis, TimeUnit.MILLISECONDS)) {
  49. executor.shutdownNow();
  50. throw new TimeoutException("Timeout occurred while fetching nested entries.");
  51. }
  52. } catch (InterruptedException e) {
  53. executor.shutdownNow();
  54. Thread.currentThread().interrupt();
  55. throw new TimeoutException("Timeout occurred while fetching nested entries.");
  56. }
  58. return allEntries;
  59. }
  61. public static void main(String[] args) {
  62. try {
  63. List<Entry> entries = fetchNestedEntries(10, 500); // Fetch 10 entries with a 500ms timeout
  64. for (Entry entry : entries) {
  65. System.out.println("ID: " + entry.getId() + ", Data: " + entry.getData());
  66. }
  67. } catch (TimeoutException e) {
  68. System.err.println("Error: " + e.getMessage());
  69. }
  70. }
  71. }

Add your comment