Package java.util.concurrent.atomic

Examples of java.util.concurrent.atomic.AtomicInteger.incrementAndGet()

568
569
570
571
572
573
574
575
576
577
578
            counter.incrementAndGet();
          }

          else if (mode.get() == 1) {
            assertFalse(CoreUtils.isTitleChange(events));
            counter.incrementAndGet();
          }
        }
      };

      DynamicDAO.addEntityListener(INews.class, listener);
View Full Code Here
753
754
755
756
757
758
759
760
761
762
763
          assertEquals(1, events.size());

          if (mode.get() == 0) {
            assertTrue(CoreUtils.containsState(events, INews.State.NEW));
            assertFalse(CoreUtils.containsState(events, INews.State.READ));
            counter.incrementAndGet();
          }

          else if (mode.get() == 1) {
            assertTrue(CoreUtils.containsState(events, INews.State.READ));
            assertFalse(CoreUtils.containsState(events, INews.State.NEW));
View Full Code Here
759
760
761
762
763
764
765
766
767
768
769
          }

          else if (mode.get() == 1) {
            assertTrue(CoreUtils.containsState(events, INews.State.READ));
            assertFalse(CoreUtils.containsState(events, INews.State.NEW));
            counter.incrementAndGet();
          }
        }
      };

      DynamicDAO.addEntityListener(INews.class, listener);
View Full Code Here
121
122
123
124
125
126
127
128
129
130
131
        final AtomicInteger added = new AtomicInteger(0);
       
        bin.connect(new Bin.ELEMENT_ADDED() {
            public void elementAdded(Bin bin, Element elem) {
                if (elem == e1 || elem == e2) {
                    added.incrementAndGet();
                }
            }
        });
        bin.addMany(e1, e2);
       
View Full Code Here
139
140
141
142
143
144
145
146
147
148
149
        final AtomicInteger removed = new AtomicInteger(0);
       
        bin.connect(new Bin.ELEMENT_ADDED() {
            public void elementAdded(Bin bin, Element elem) {
                if (elem == e1 || elem == e2) {
                    removed.incrementAndGet();
                }
            }
        });
        bin.addMany(e1, e2);
       
View Full Code Here
133
134
135
136
137
138
139
140
141
142
143
           
            public void onRequest(IHttpExchange exchange) throws IOException, BadMessageException {
               
                BodyDataSink ds = exchange.send(new HttpResponseHeader(200, "text/event-stream"));
               
                ds.write("data: " + numRequests.incrementAndGet() + "\n");
                ds.write("id: 4\n");
               
                if (numRequests.get() == 1) {
                    ds.destroy();
                } else {
View Full Code Here
87
88
89
90
91
92
93
94
95
96
97
        final Character cc = Character.toLowerCase(c);
        final AtomicInteger i = this.letter.get(cc);
        if (i == null) {
            this.letter.put(cc, new AtomicInteger(1));
        } else {
            i.incrementAndGet();
        }
        this.letters++;
    }

    public void add(final String word) {
View Full Code Here
113
114
115
116
117
118
119
120
121
122
123
   
    public void inc(final E obj) {
        if (obj == null) return;
        AtomicInteger score = this.map.get(obj);
        if (score != null) {
            score.incrementAndGet();
            return;
        }
        synchronized (map) {
            score = this.map.get(obj);
            if (score == null) {
View Full Code Here
123
124
125
126
127
128
129
130
131
132
133
            if (score == null) {
                this.map.put(obj, new AtomicInteger(1));
                return;
            }
        }
        score.incrementAndGet();
    }
   
    public void dec(final E obj) {
        if (obj == null) return;
        AtomicInteger score;
View Full Code Here
76
77
78
79
80
81
82
83
84
85
86
      AtomicInteger counter = counters.get(outputWriter.getJdbcUrl());
      if (counter == null) {
        counter = new AtomicInteger();
        counters.put(outputWriter.getJdbcUrl(), counter);
      }
      counter.incrementAndGet();

      return outputWriter;
    }
  }
View Full Code Here
TOP
Copyright © 2018 www.massapi.com. All rights reserved.
All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.