Package org.apache.commons.collections

Examples of org.apache.commons.collections.Buffer.addAll()

55
56
57
58
59
60
61
62
63
64
65
        return UnmodifiableBuffer.decorate(new UnboundedFifoBuffer());
    }
   
    public Collection makeFullCollection() {
        Buffer buffer = new UnboundedFifoBuffer();
        buffer.addAll(Arrays.asList(getFullElements()));
        return UnmodifiableBuffer.decorate(buffer);
    }
   
    public Collection makeConfirmedCollection() {
        ArrayStack list = new ArrayStack();
View Full Code Here
55
56
57
58
59
60
61
62
63
64
65
        return SynchronizedBuffer.decorate(new UnboundedFifoBuffer());
    }
   
    public Collection makeFullCollection() {
        Buffer buffer = new UnboundedFifoBuffer();
        buffer.addAll(Arrays.asList(getFullElements()));
        return SynchronizedBuffer.decorate(buffer);
    }
   
    public Collection makeConfirmedCollection() {
        ArrayStack list = new ArrayStack();
View Full Code Here
173
174
175
176
177
178
179
180
181
182
183
       
        // give hungry read threads ample time to hang
        delay();
          
        // notifyAll should allow both read threads to complete
        blockingBuffer.addAll(Collections.singleton(obj));
              
        // allow notified threads to complete
        delay();
       
        // There should not be any threads waiting.
View Full Code Here
275
276
277
278
279
280
281
282
283
284
285
        thread2.start();
       
        // give hungry read threads ample time to hang
        delay();
          
        blockingBuffer.addAll(Collections.singleton(obj));
       
        // allow notified threads to complete
        delay();
       
        // There should be one thread waiting.
View Full Code Here
283
284
285
286
287
288
289
290
291
292
293
        delay();
       
        // There should be one thread waiting.
        assertTrue ("There is one thread waiting", thread1.isAlive() ^ thread2.isAlive());
          
        blockingBuffer.addAll(Collections.singleton(obj));
       
        // allow notified thread to complete
        delay();

        // There should not be any threads waiting.
View Full Code Here
322
323
324
325
326
327
328
329
330
331
332
        thread2.start();
       
        // give hungry read threads ample time to hang
        delay();
          
        blockingBuffer.addAll(objs);
       
        // allow notified threads to complete
        delay();
       
        assertEquals("Both objects were removed", 0, objs.size());
View Full Code Here
56
57
58
59
60
61
62
63
64
65
66
        return SynchronizedBuffer.decorate(new UnboundedFifoBuffer());
    }
   
    public Collection makeFullCollection() {
        Buffer buffer = new UnboundedFifoBuffer();
        buffer.addAll(Arrays.asList(getFullElements()));
        return SynchronizedBuffer.decorate(buffer);
    }
   
    public Collection makeConfirmedCollection() {
        ArrayStack list = new ArrayStack();
View Full Code Here
56
57
58
59
60
61
62
63
64
65
66
        return UnmodifiableBuffer.decorate(new UnboundedFifoBuffer());
    }
   
    public Collection makeFullCollection() {
        Buffer buffer = new UnboundedFifoBuffer();
        buffer.addAll(Arrays.asList(getFullElements()));
        return UnmodifiableBuffer.decorate(buffer);
    }
   
    public Collection makeConfirmedCollection() {
        ArrayStack list = new ArrayStack();
View Full Code Here
89
90
91
92
93
94
95
96
97
98
99
    public void testAddAllToFullBufferNoTimeout() {
        final Buffer bounded = BoundedBuffer.decorate(new UnboundedFifoBuffer(), 1);
        bounded.add( "Hello" );
        try {
            bounded.addAll(Collections.singleton("World"));
            fail();
        } catch (BufferOverflowException e) {
        }
    }
View Full Code Here
98
99
100
101
102
103
104
105
106
107
108
    }

    public void testAddAllToEmptyBufferExceedMaxSizeNoTimeout() {
        final Buffer bounded = BoundedBuffer.decorate(new UnboundedFifoBuffer(), 1);
        try {
            bounded.addAll(Collections.nCopies(2, "test"));
            fail();
        } catch (BufferOverflowException e) {
        }
    }
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.