Java 类com.google.common.base.FinalizableReferenceQueue 实例源码

项目:yar    文件:SimpleRegistry.java   
SimpleRegistry(WatchableRegistrationContainer registrationContainer, long timeout, TimeUnit unit) {
    referenceQueue = new FinalizableReferenceQueue();
    this.registrationContainer = registrationContainer;
    //TODO test performance of the linked vs. array or any other blocking. may provide a new builder feature to setup the size of the queue
    registryActionQueue = new LinkedBlockingQueue<>();
    Thread registryActionThread = new Thread(new RegistryActionHandler(registryActionQueue), "yar-action-handler");
    registryActionThread.setDaemon(true);
    registryActionThread.start();
    this.defaultTimeOut = timeout;
    this.defaultTimeoutUnit = unit;
}
项目:yangtools    文件:GuavaObjectCache.java   
GuavaObjectCache(final FinalizableReferenceQueue  queue) {
    super(CacheBuilder.newBuilder().softValues().build(), queue);
}
项目:yangtools    文件:GuavaObjectCache.java   
GuavaObjectCache(final FinalizableReferenceQueue  queue, final CacheBuilderSpec spec) {
    super(CacheBuilder.from(spec).build(), queue);
}
项目:yangtools    文件:AbstractObjectCache.java   
public SoftKey(final T referent, final FinalizableReferenceQueue queue) {
    super(requireNonNull(referent), queue);
    hashCode = referent.hashCode();
}
项目:yangtools    文件:AbstractObjectCache.java   
protected AbstractObjectCache(final Cache<SoftKey<?>, Object> cache, final FinalizableReferenceQueue queue) {
    this.queue = requireNonNull(queue);
    this.cache = requireNonNull(cache);
}
项目:yangtools    文件:CacheTest.java   
@Before
public void setUp() {
    queue = new FinalizableReferenceQueue();
    oc = new AbstractObjectCache(CacheBuilder.newBuilder().softValues().build(), queue) {
    };
}
项目:yangtools    文件:SoftKeyTest.java   
@Before
public void setUp() {
    queue = new FinalizableReferenceQueue();
}
项目:yar    文件:WatcherRegistration.java   
static <T> WatcherRegistration<T> newWatcherRegistration(IdMatcher<T> leftValue, SupplierListener supplierListener, FinalizableReferenceQueue referenceQueue, Registry registry) {
    return new WatcherRegistration<>(leftValue, supplierListener, new SupplierWatcherToSupplierListenerAdapter<T>(supplierListener), referenceQueue, registry);
}
项目:yar    文件:WatcherRegistration.java   
@SuppressWarnings("unchecked")
static <T> WatcherRegistration<T> newWatcherRegistration(IdMatcher<T> leftValue, Watcher<T> rightValue, FinalizableReferenceQueue referenceQueue, Registry registry) {
    return new WatcherRegistration(leftValue, rightValue, new WatcherDecorator<>(rightValue), referenceQueue, registry);
}
项目:yar    文件:WatcherRegistration.java   
WatcherRegistration(IdMatcher<T> leftValue, Object weakReference, Watcher<T> rightValue, FinalizableReferenceQueue referenceQueue, Registry registry) {
    super(weakReference, referenceQueue);
    left = leftValue;
    right = rightValue;
    this.registry = registry;
}