Searched refs:ConcurrentBufferQueue (Results 1 – 7 of 7) sorted by relevance
30 ConcurrentBufferQueue.UnusedElementProcessor<T> {31 private final ConcurrentBufferQueue.UnusedElementProcessor mProcessor;33 private DecrementingProcessor(ConcurrentBufferQueue.UnusedElementProcessor<T> processor) { in DecrementingProcessor()44 private final ConcurrentBufferQueue<T> mBufferQueue;55 public CountableBufferQueue(Updatable<Integer> sizeCallback, ConcurrentBufferQueue in CountableBufferQueue()57 mBufferQueue = new ConcurrentBufferQueue<T>(new DecrementingProcessor<T>(processor)); in CountableBufferQueue()64 this(sizeCallback, new ConcurrentBufferQueue.UnusedElementProcessor<T>() { in CountableBufferQueue()
40 public class ConcurrentBufferQueue<T> implements BufferQueue<T>, BufferQueueController<T>, class93 public ConcurrentBufferQueue(UnusedElementProcessor<T> unusedElementProcessor) { in ConcurrentBufferQueue() method in ConcurrentBufferQueue100 public ConcurrentBufferQueue() { in ConcurrentBufferQueue() method in ConcurrentBufferQueue
21 import com.android.camera.async.ConcurrentBufferQueue;43 ConcurrentBufferQueue<Long> globalTimestampStream = new ConcurrentBufferQueue<>(); in ImageDistributorFactory()
24 import com.android.camera.async.ConcurrentBufferQueue;100 ConcurrentBufferQueue<ImageProxy> imageStream = new ConcurrentBufferQueue<>(new in createUnallocatedStream()
19 import com.android.camera.async.ConcurrentBufferQueue;22 public class ImageCloser implements ConcurrentBufferQueue.UnusedElementProcessor<ImageProxy> {
32 import com.android.camera.async.ConcurrentBufferQueue;169 ConcurrentBufferQueue<Long> timestamps = new ConcurrentBufferQueue<>(); in addStream()
23 import com.android.camera.async.ConcurrentBufferQueue;