ThreadedAccumulator (venice API)

java.lang.Object

com.linkedin.alpini.base.concurrency.ThreadedAccumulator<T,A,R>

All Implemented Interfaces:: Consumer<T>, Supplier<R>

public class ThreadedAccumulator<T,A,R> extends Object implements Consumer<T>, Supplier<R>

Method Summary

Modifier and Type

Method

Description

void

accept(T t)

R

get()

R

getThenReset()

void

pack()

void

reset()

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface java.util.function.Consumer
andThen

Method Details
- getThenReset
  
  public R getThenReset()
- get
  
  public R get()
  
  Specified by:
  
  get in interface Supplier<T>
- reset
  
  public void reset()
- accept
  
  public void accept(T t)
  
  Specified by:
  
  accept in interface Consumer<T>
- pack
  
  public void pack()