Guest User

Untitled

a guest
Jun 19th, 2020
134
0
Never
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
text 2.06 KB | None | 0 0
  1. Zadanie
  2.  
  3. ● Utworzyć projekt maven lub gradle.
  4.  
  5. ● Przekleić zawartość załączników do pliku Item.java, uzupełnić brakujące importy.
  6.  
  7. Wątki
  8.  
  9. ● Utworzyć listę 100 obiektów klasy Item
  10.  
  11. ● Utworzyć 4 wątki produkujące (wywołujące metodę produceMe()), oraz 3 wątki
  12.  
  13. konsumujące (wywołujące metodę consumeMe()).
  14.  
  15. ● Zaimplementować aplikację w taki sposób aby wszystkie obiekty z listy były “wyprodukowane” przez wątki produkujące i “skonsumowane” przez wątki konsumujące. Zrealizować to w taki sposób aby czas zminimalizować czas produkcji i konsumpcji wszystkich obiektów.
  16.  
  17. Pule wątków
  18.  
  19. ● Utworzyć pulę wątków.
  20.  
  21. ● Wykonać zadanie z poprzedniego podpunktu tak, aby wykorzystać w tym celu pulę wątków, z tym że bez podziału na wątki produkujące i konsumujące (pojedynczy wątek, w zależności od potrzeb może wykonywać obydwa zadania).
  22.  
  23. ● Wykonać testy dla różnych typów puli wątków
  24.  
  25.  
  26. Item:
  27.  
  28. public class Item {
  29.  
  30. private static final AtomicInteger COUNTER = new AtomicInteger(); private final String name;
  31. private volatile boolean produced = false; private volatile boolean consumed = false;
  32.  
  33. public Item() {
  34.  
  35. this.name = "Item-" + COUNTER.getAndIncrement();
  36.  
  37. }
  38.  
  39. public synchronized void produceMe() {
  40.  
  41. if (produced) {
  42.  
  43. throw new RuntimeException(name + " already produced");
  44.  
  45. }
  46.  
  47. if (consumed) {
  48.  
  49. throw new RuntimeException(name + " already consumed");
  50.  
  51. }
  52.  
  53. System.out.println("Producing: " + name);
  54.  
  55. delay(2);
  56.  
  57. produced = true;
  58.  
  59. System.out.println("Produced: " + name);
  60.  
  61. }
  62.  
  63. public synchronized void consumeMe() {
  64.  
  65. if (!produced) {
  66.  
  67. throw new RuntimeException(name + " not produced yet");
  68.  
  69. }
  70.  
  71. if (consumed) {
  72.  
  73. throw new RuntimeException(name + " already consumed");
  74.  
  75. }
  76.  
  77. System.out.println("Consuming: " + name);
  78.  
  79. delay(3);
  80.  
  81. consumed = true;
  82.  
  83. System.out.println("Consumed: " + name);
  84.  
  85. }
  86.  
  87. private void delay(int seconds) {
  88.  
  89. try {
  90.  
  91. Thread.sleep(seconds * 1000);
  92.  
  93. } catch (InterruptedException ex) {
  94.  
  95. ex.printStackTrace();
  96.  
  97. }
  98.  
  99. }
  100.  
  101. }
Advertisement
Add Comment
Please, Sign In to add comment