1. Java / Говнокод #8513

    +71

    1. 01
    2. 02
    3. 03
    4. 04
    5. 05
    6. 06
    7. 07
    8. 08
    9. 09
    10. 10
    11. 11
    12. 12
    13. 13
    14. 14
    15. 15
    16. 16
    17. 17
    18. 18
    19. 19
    20. 20
    21. 21
    22. 22
    23. 23
    24. 24
    25. 25
    26. 26
    27. 27
    28. 28
    29. 29
    30. 30
    31. 31
    32. 32
    33. 33
    34. 34
    35. 35
    36. 36
    37. 37
    38. 38
    39. 39
    40. 40
    41. 41
    42. 42
    43. 43
    44. 44
    45. 45
    46. 46
    47. 47
    48. 48
    49. 49
    public class AuthorizedUserObservervable implements Runnable {

    private long sleepTime = 1000;
    private HashMap<AuthorizedUserObserver, HashMap<AuthorizedUser, Integer>> observers = new HashMap<AuthorizedUserObserver, HashMap<AuthorizedUser, Integer>>();
    
    
    private void setSleepTime(long sleepTime) {
        this.sleepTime = sleepTime;
    }
    
    
    public void add(AuthorizedUserObserver auo) {
        HashMap<AuthorizedUser, Integer> userCache = new HashMap<AuthorizedUser, Integer>();
        for (AuthorizedUser user : auo.getUsers()) {
            userCache.put(user, null);
        }
        observers.put(auo, userCache);
    }

    public void beginObservation() {
        new Thread(this).start();
    }

    @Override
    public void run() {
        while (true) {
            try {
                for (Map.Entry<AuthorizedUserObserver, HashMap<AuthorizedUser, Integer>> observer : observers.entrySet()) {
                    for (Map.Entry<AuthorizedUser, Integer> user : observer.getValue().entrySet()) {
                        int newPostsCount = user.getKey().getNewPostsCount();
                        if (user.getValue() == null || newPostsCount != user.getValue()) {
                            HashMap<AuthorizedUser, Integer> userCache = new HashMap<AuthorizedUser, Integer>();
                            userCache.put(user.getKey(), newPostsCount);
                            observers.put(observer.getKey(), userCache);
                            observer.getKey().notify(user.getKey(), newPostsCount);
                        }
                    }
                }


                Thread.sleep(sleepTime);
            } catch (InterruptedException ex) {
                Logger.getLogger(UserObservervable.class.getName()).log(Level.SEVERE, null, ex);
            } catch (AuthenticationException e) {
                Thread.currentThread().stop(e);
            }
        }
    }
}

    Чего стоит гибкость.

    Запостил: manyrus, 13 Ноября 2011

    Комментарии (2) RSS

    • ava guest 15.11.2011 23:30 # 0

      А прикол в том что он переменил коллекции ? обобщенное программирование не люблю читать портянки.
      Ответить

    • ava tir 16.11.2011 07:42 # 0

      я бы рекомендовал для observers использовать ConcurentHashMap, т. к. метод add() видимо вызывается из другого потока, а HashMap не является потокобезопасным.
      Ответить

    Добавить комментарий