1. import java.util.LinkedList;
  2. import java.util.Queue;
  3. import java.util.List;
  4. import java.util.ArrayList;
  5. import java.util.concurrent.ExecutorService;
  6. import java.util.concurrent.Executors;
  7. import java.util.concurrent.TimeUnit;
  9. public class HeaderValidator {
  11. private final Queue<HeaderMetadata> taskQueue = new LinkedList<>();
  12. private final List<HeaderMetadata> failedTasks = new ArrayList<>();
  13. private final ExecutorService executorService = Executors.newFixedThreadPool(10); //Adjust thread pool size
  14. private final int maxFailedTasks = 100; //Limit number of failed tasks to prevent unbounded accumulation
  16. public void enqueueTask(HeaderMetadata task) {
  17. taskQueue.offer(task);
  18. }
  20. public List<HeaderMetadata> getFailedTasks() {
  21. return failedTasks;
  22. }
  25. public void startValidation() {
  26. while (true) {
  27. HeaderMetadata task = taskQueue.poll();
  29. if (task == null) {
  30. break; //Queue is empty
  31. }
  33. executorService.execute(() -> {
  34. try {
  35. validateHeaderMetadata(task);
  36. } catch (Exception e) {
  37. System.err.println("Validation failed for: " + task + ". Error: " + e.getMessage());
  38. failedTasks.add(task);
  39. }
  40. });
  41. }
  42. executorService.shutdown();
  43. try {
  44. executorService.awaitTermination(60, TimeUnit.SECONDS); //Give threads time to finish
  45. } catch (InterruptedException e) {
  46. System.err.println("Executor termination interrupted: " + e.getMessage());
  47. }
  48. }
  51. private void validateHeaderMetadata(HeaderMetadata task) throws Exception {
  52. // Simulate validation logic. Replace with your actual validation checks.
  53. if (!task.isValid()) {
  54. throw new IllegalArgumentException("Header metadata is invalid: " + task);
  55. }
  56. System.out.println("Validation successful for: " + task);
  57. }
  60. //Inner class to represent header metadata
  61. public static class HeaderMetadata {
  62. private final String headerName;
  63. private final String headerValue;
  65. public HeaderMetadata(String headerName, String headerValue) {
  66. this.headerName = headerName;
  67. this.headerValue = headerValue;
  68. }
  70. public String getHeaderName() {
  71. return headerName;
  72. }
  74. public String getHeaderValue() {
  75. return headerValue;
  76. }
  78. public boolean isValid() {
  79. //Replace with your validation logic
  80. return headerValue != null && !headerValue.isEmpty();
  81. }
  83. @Override
  84. public String toString() {
  85. return "HeaderMetadata{" +
  86. "headerName='" + headerName + '\'' +
  87. ", headerValue='" + headerValue + '\'' +
  88. '}';
  89. }
  90. }
  94. public static void main(String[] args) throws InterruptedException {
  95. HeaderValidator validator = new HeaderValidator();
  97. //Create some header metadata
  98. List<HeaderMetadata> tasks = new ArrayList<>();
  99. tasks.add(new HeaderMetadata("Content-Type", "application/json"));
  100. tasks.add(new HeaderMetadata("Authorization", "Bearer token"));
  101. tasks.add(new HeaderMetadata("Content-Type", "")); //Invalid
  102. tasks.add(new HeaderMetadata("X-Custom-Header", null)); //Invalid
  103. tasks.add(new HeaderMetadata("User-Agent", "MyApplication/1.0"));
  105. //Enqueue the tasks
  106. for (HeaderMetadata task : tasks) {
  107. validator.enqueueTask(task);
  108. }
  110. //Start the validation process
  111. validator.startValidation();
  113. System.out.println("Validation complete. Failed tasks: " + validator.getFailedTasks());
  114. }
  116. }

Add your comment