1. import java.util.*;
  2. import java.util.concurrent.*;
  3. import java.util.concurrent.atomic.AtomicInteger;
  5. public class ResourceSync {
  7. private final Map<String, List<Object>> resources = new HashMap<>(); // Store resources by name
  8. private final Map<String, Integer> resourceCounts = new HashMap<>(); // Track resource counts
  9. private final int maxRate = 10; // Maximum rate of synchronization
  10. private final int sleepMillis = 100; // Sleep duration between syncs
  11. private final Semaphore semaphore = new Semaphore(maxRate); // Rate limiter
  12. private final AtomicInteger syncCount = new AtomicInteger(0); //Sync counter
  15. public void addResource(String name, List<?> resource) {
  16. resources.put(name, resource);
  17. resourceCounts.put(name, 0);
  18. }
  20. public List<?> getResource(String name) {
  21. return resources.get(name);
  22. }
  24. public synchronized int getResourceCount(String name) {
  25. return resourceCounts.getOrDefault(name, 0);
  26. }
  28. public synchronized void incrementResourceCount(String name) {
  29. resourceCounts.put(name, resourceCounts.get(name) + 1);
  30. }
  32. public synchronized void resetResourceCount(String name) {
  33. resourceCounts.put(name, 0);
  34. }
  36. public void syncResources() throws InterruptedException {
  37. semaphore.acquire(); // Acquire a permit from the rate limiter
  38. try {
  39. for (Map.Entry<String, List<?>> entry : resources.entrySet()) {
  40. String name = entry.getKey();
  41. List<?> resourceList = entry.getValue();
  43. // Simulate resource synchronization (e.g., updating data)
  44. synchronized (resourceList) {
  45. // Perform synchronization operations on the resource list
  46. // Example: Increment a counter in the resource
  47. incrementResourceCount(name);
  48. }
  49. }
  50. syncCount.incrementAndGet();
  51. } finally {
  52. semaphore.release(); // Release the permit when done
  53. }
  54. }
  56. public static void main(String[] args) throws InterruptedException {
  57. ResourceSync sync = new ResourceSync();
  59. // Add some resources
  60. sync.addResource("resource1", Arrays.asList(1, 2, 3));
  61. sync.addResource("resource2", Arrays.asList("a", "b", "c"));
  63. // Simulate scheduled runs
  64. for (int i = 0; i < 5; i++) {
  65. System.out.println("Syncing resources... (Sync count: " + sync.syncCount + ")");
  66. sync.syncResources();
  67. Thread.sleep(sync.sleepMillis);
  68. }
  70. System.out.println("All syncs completed.");
  72. }
  73. }

Add your comment