| LocalFifoBuffer | Line # 9 | 7 | 6 | 71.4% |
0.71428573
|
| (3) | |||
| Result | |||
|
0.71428573
|
com.atlassian.core.task.TaskManagerTestCase.testTaskManager
com.atlassian.core.task.TaskManagerTestCase.testTaskManager
|
1 PASS | |
|
0.71428573
|
com.atlassian.core.task.MultiQueueTaskManagerTestCase.testTaskManager
com.atlassian.core.task.MultiQueueTaskManagerTestCase.testTaskManager
|
1 PASS | |
|
0.71428573
|
com.atlassian.core.task.ErrorQueueTaskQueueTestCase.testTaskManager
com.atlassian.core.task.ErrorQueueTaskQueueTestCase.testTaskManager
|
1 PASS | |
| 1 | package com.atlassian.core.task; | |
| 2 | ||
| 3 | import org.apache.commons.collections.Buffer; | |
| 4 | import org.apache.commons.collections.BufferUtils; | |
| 5 | import org.apache.commons.collections.buffer.UnboundedFifoBuffer; | |
| 6 | ||
| 7 | import java.util.Collection; | |
| 8 | ||
| 9 | public class LocalFifoBuffer implements FifoBuffer | |
| 10 | { | |
| 11 | private Buffer buffer = BufferUtils.synchronizedBuffer(new UnboundedFifoBuffer()); | |
| 12 | ||
| 13 | 15 |
public synchronized Object remove() |
| 14 | { | |
| 15 | 15 | if (!buffer.isEmpty()) |
| 16 | 9 | return buffer.remove(); |
| 17 | else | |
| 18 | 6 | return null; |
| 19 | } | |
| 20 | ||
| 21 | 10 |
public void add(Object o) |
| 22 | { | |
| 23 | 10 | buffer.add(o); |
| 24 | } | |
| 25 | ||
| 26 | 10 |
public int size() |
| 27 | { | |
| 28 | 10 | return buffer.size(); |
| 29 | } | |
| 30 | ||
| 31 | 0 |
public Collection getItems() |
| 32 | { | |
| 33 | 0 | return buffer; |
| 34 | } | |
| 35 | ||
| 36 | 0 |
public void clear() |
| 37 | { | |
| 38 | 0 | buffer.clear(); |
| 39 | } | |
| 40 | } | |
|
||||||||||