Java Code Examples for java.lang.ref.WeakReference

private Image getCache(){
  WeakReference cache=this.cache;
  if (cache != null) {
    Image image=(Image)cache.get();
    if (image != null) {
      if (cacheColor == color) {
        return image;
      }
    }
  }
  Image image=Image.createRGBImage(argbData,width,height,true);
  cache=new WeakReference(image);
  return image;
}
 

/** 
 * Registers a  {@link CursorableLinkedList.Cursor} to be notifiedof changes to this list.
 */
protected void registerCursor(Cursor cur){
  for (Iterator it=_cursors.iterator(); it.hasNext(); ) {
    WeakReference ref=(WeakReference)it.next();
    if (ref.get() == null) {
      it.remove();
    }
  }
  _cursors.add(new WeakReference(cur));
}
 

@Test @SuppressWarnings("IncompatibleEquals") public void equals() throws Exception {
  String o=new String();
  WeakReference ref0=new UnwrappedWeakReference(o);
  WeakReference ref1=new UnwrappedWeakReference(o);
  Assert.assertTrue(ref0.equals(ref1));
  Assert.assertTrue(ref0.equals(o));
  Assert.assertTrue(ref1.equals(o));
}
 

/** 
 * Deregisters a cursor from the list to be notified of changes.
 * @param cursor the cursor to deregister
 */
protected void unregisterCursor(Cursor<E> cursor){
  for (Iterator it=cursors.iterator(); it.hasNext(); ) {
    WeakReference ref=(WeakReference)it.next();
    Cursor cur=(Cursor)ref.get();
    if (cur == null) {
      it.remove();
    }
 else     if (cur == cursor) {
      ref.clear();
      it.remove();
      break;
    }
  }
}
 

/** 
 * Registers a  {@link CursorableLinkedList.Cursor} to be notifiedof changes to this list.
 */
protected void registerCursor(Cursor cur){
  for (Iterator it=_cursors.iterator(); it.hasNext(); ) {
    WeakReference ref=(WeakReference)it.next();
    if (ref.get() == null) {
      it.remove();
    }
  }
  _cursors.add(new WeakReference(cur));
}
 

SamsungWidgetsLoader(Context context){
  this$0=SamsungWidgetPackageManager.this;
  Object();
  mRunning=true;
  mContext=new WeakReference(context);
}
 

@Override public void launch(){
  Preferences _prefs=Preferences.userNodeForPackage(digestMultiple.class);
  String uuid=_prefs.get("DefaultCollection","");
  Collection joshcoll=Collector.getCollection(uuid);
  if (joshcoll != null) {
    digestMultiple v=new digestMultiple(joshcoll);
    pig.add(new WeakReference(v));
    return;
  }
  Collection chosen=new Collection();
  digestMultiple v=new digestMultiple(chosen);
  pig.add(new WeakReference(v));
}
 

public void testRelease() throws Exception {
  assertNotNull(weakHashtable.get(new Long(1)));
  ReferenceQueue testQueue=new ReferenceQueue();
  WeakReference weakKeyOne=new WeakReference(keyOne,testQueue);
  keyOne=null;
  keyTwo=null;
  keyThree=null;
  valueOne=null;
  valueTwo=null;
  valueThree=null;
  int iterations=0;
  int bytz=2;
  while (true) {
    System.gc();
    if (iterations++ > MAX_GC_ITERATIONS) {
      fail("Max iterations reached before resource released.");
    }
    if (weakHashtable.get(new Long(1)) == null) {
      break;
    }
 else {
      byte[] b=new byte[bytz];
      bytz=bytz * 2;
    }
  }
  while (testQueue.poll() == null) {
  }
  assertEquals("underlying table not emptied",0,weakHashtable.size());
}
 

public static Keyword intern(Symbol sym){
  if (sym.meta() != null)   sym=(Symbol)sym.withMeta(null);
  Util.clearCache(rq,table);
  Keyword k=new Keyword(sym);
  Reference<Keyword> existingRef=table.putIfAbsent(sym,new WeakReference<Keyword>(k,rq));
  if (existingRef == null)   return k;
  Keyword existingk=existingRef.get();
  if (existingk != null)   return existingk;
  table.remove(sym,existingRef);
  return intern(sym);
}
 

private AnimatorProxy(View view){
  setDuration(0);
  setFillAfter(true);
  view.setAnimation(this);
  mView=new WeakReference<View>(view);
}
 

private AnimatorProxy(View view){
  setDuration(0);
  setFillAfter(true);
  view.setAnimation(this);
  mView=new WeakReference<View>(view);
}
 

/** 
 * Remove a presenter from this menu. That presenter will no longer receive notifications of updates to this menu's data.
 * @param presenter The presenter to remove
 */
public void removeMenuPresenter(SimpleMenuPresenter presenter){
  for (  WeakReference<SimpleMenuPresenter> ref : mPresenters) {
    final SimpleMenuPresenter item=ref.get();
    if (item == null || item == presenter) {
      mPresenters.remove(ref);
    }
  }
}
 

private AnimatorProxy(View view){
  setDuration(0);
  setFillAfter(true);
  view.setAnimation(this);
  mView=new WeakReference<View>(view);
}
 

public synchronized boolean addPermissionLinker(final PermissionLinker perm){
  final String name=perm.getName();
  if (name == null) {
    throw new NullPointerException();
  }
  final WeakReference<PermissionLinker> ref=permissionLinkers.get(name);
  if (ref != null) {
    if (ref.get() == null) {
      permissionLinkers.remove(name);
    }
 else {
      return false;
    }
  }
  permissionLinkers.put(name,new WeakReference<PermissionLinker>(perm));
  return true;
}
 

public synchronized T intern(T object){
  Reference<T> pooledRef=objects.get(object);
  if (pooledRef != null) {
    T pooled=pooledRef.get();
    if (pooled != null) {
      return pooled;
    }
  }
  objects.put(object,new WeakReference<T>(object));
  return object;
}
 

public HeadsUpPageRequestTargetUrlCodingStrategy(String mount,Class page){
  super(mount);
  if (page == null) {
    throw new IllegalArgumentException("Argument bookmarkablePageClass must be not null");
  }
  bookmarkablePageClassRef=new WeakReference<Class<? extends Page>>(page);
}
 

/** 
 * Creates a new Exportable object.
 * @param exporter the exporter to use
 * @throws RemoteException on an export error
 */
protected Exportable(Exporter exporter) throws RemoteException {
  this.exporter=exporter;
  exported=new WeakReference<Remote>(exporter.exportObject(this));
  if (log.isDebugEnabled()) {
    String client=getClient();
    if (client != null)     log.debug("Exported " + this + " for "+ client);
 else     log.debug("Exported " + this + " for all clients.");
  }
}
 

private AnimatorProxy(View view){
  setDuration(0);
  setFillAfter(true);
  view.setAnimation(this);
  mView=new WeakReference<View>(view);
}
 

public void addFutureListener(FutureListener<RV> futureListener){
  if (isDone()) {
    if (this.throwable == null) {
      notifyListener(futureListener);
    }
 else {
      notifyListenerException(futureListener);
    }
  }
 else {
    this.writeListenersLock.lock();
    try {
      WeakReference<FutureListener<RV>> listener=new WeakReference<FutureListener<RV>>(futureListener);
      if (!this.listeners.contains(listener)) {
        this.listeners.add(listener);
      }
    }
  finally {
      this.writeListenersLock.unlock();
    }
  }
}
 

private AnimatorProxy(View view){
  setDuration(0);
  setFillAfter(true);
  view.setAnimation(this);
  mView=new WeakReference<View>(view);
}
 

@Provides IssueStore issueStore(IssueService issueService,PullRequestService pullService){
  IssueStore store=issues != null ? issues.get() : null;
  if (store == null) {
    store=new IssueStore(issueService,pullService);
    issues=new WeakReference<IssueStore>(store);
  }
  return store;
}
 

/** 
 * Cancels any pending (or potentially active) requests associated with the passed Context. <p> <b>Note:</b> This will only affect requests which were created with a non-null android Context. This method is intended to be used in the onDestroy method of your android activities to destroy all requests which are no longer required.
 * @param context the android Context instance associated to the request.
 * @param mayInterruptIfRunning specifies if active requests should be cancelled along with pending requests.
 */
public void cancelRequests(Context context,boolean mayInterruptIfRunning){
  List<WeakReference<Future<?>>> requestList=requestMap.get(context);
  if (requestList != null) {
    for (    WeakReference<Future<?>> requestRef : requestList) {
      Future<?> request=requestRef.get();
      if (request != null) {
        request.cancel(mayInterruptIfRunning);
      }
    }
  }
  requestMap.remove(context);
}
 

/** 
 * Open the database according to the flags  {@link #OPEN_READWRITE}{@link #OPEN_READONLY} {@link #CREATE_IF_NECESSARY} and/or {@link #NO_LOCALIZED_COLLATORS}. <p>Sets the locale of the database to the  the system's current locale. Call  {@link #setLocale} if you would like something else.</p>
 * @param path to database file to open and/or create
 * @param factory an optional factory class that is called to instantiate acursor when query is called, or null for default
 * @param flags to control database access mode
 * @return the newly opened database
 * @throws SQLiteException if the database cannot be opened
 */
public static SQLiteDatabase openDatabase(String path,String password,CursorFactory factory,int flags,SQLiteDatabaseHook databaseHook){
  SQLiteDatabase sqliteDatabase=null;
  try {
    sqliteDatabase=new SQLiteDatabase(path,password,factory,flags,databaseHook);
    if (SQLiteDebug.DEBUG_SQL_STATEMENTS) {
      sqliteDatabase.enableSqlTracing(path);
    }
    if (SQLiteDebug.DEBUG_SQL_TIME) {
      sqliteDatabase.enableSqlProfiling(path);
    }
  }
 catch (  SQLiteDatabaseCorruptException e) {
    Log.e(TAG,"Deleting and re-creating corrupt database " + path,e);
    if (!path.equalsIgnoreCase(":memory")) {
      new File(path).delete();
    }
    sqliteDatabase=new SQLiteDatabase(path,password,factory,flags,databaseHook);
  }
  ActiveDatabases.getInstance().mActiveDatabases.add(new WeakReference<SQLiteDatabase>(sqliteDatabase));
  return sqliteDatabase;
}
 

public void registerAction(ActionBusListener actionBusListener,Integer... actions){
  if (null == actionBusListener || null == actions) {
    return;
  }
  for (  Integer action : actions) {
    List<WeakReference<ActionBusListener>> listeners=actionBusListeners.get(action);
    if (null == listeners) {
      listeners=new ArrayList<WeakReference<ActionBusListener>>();
    }
    removeReference(listeners,actionBusListener);
    listeners.add(new WeakReference<ActionBusListener>(actionBusListener));
    actionBusListeners.put(action,listeners);
  }
}
 

public boolean setView(int index,View view){
  UI.assertInMainThread();
  this.index=index;
  if (getView() == view && (screenshot != null || TextureUtils.isValidTexture(texture)))   return false;
  viewRef=null;
  if (texture != null) {
    texture.postDestroy();
    texture=null;
  }
  if (view != null) {
    viewRef=new WeakReference<View>(view);
    UI.recycleBitmap(screenshot);
    screenshot=GrabIt.takeScreenshot(view);
  }
 else {
    UI.recycleBitmap(screenshot);
  }
  return true;
}
 

@Override protected void populateQuickActions(List<QuickAction> quickActions){
  mQuickActions=quickActions;
  final LayoutInflater inflater=LayoutInflater.from(getContext());
  for (  QuickAction action : quickActions) {
    TextView view=(TextView)inflater.inflate(R.layout.gd_quick_action_bar_item,mQuickActionItems,false);
    view.setText(action.mTitle);
    view.setCompoundDrawablesWithIntrinsicBounds(null,action.mDrawable,null,null);
    view.setOnClickListener(mClickHandlerInternal);
    mQuickActionItems.addView(view);
    action.mView=new WeakReference<View>(view);
  }
}
 

/** 
 * Should be call at  {@link Activity#onStart()} 
 */
public void registerListeners(Activity context){
  this.context=new WeakReference<Activity>(context);
  FacebookEvents.addAuthListener(authListener);
  FacebookEvents.addPostListener(postListener);
  FacebookEvents.addLogoutListener(logoutListener);
}
 

/** 
 * Set a callback handler with a weak reference. Use weak handler if you do not want the ajax callback to hold the handler object from garbage collection. For example, if the handler is an activity, weakHandler should be used since the method shouldn't be invoked if an activity is already dead and garbage collected.
 * @param handler the handler
 * @param callback the callback
 * @return self
 */
public K weakHandler(Object handler,String callback){
  this.whandler=new WeakReference<Object>(handler);
  this.callback=callback;
  this.handler=null;
  return self();
}
 

private AnimatorProxy(View view){
  setDuration(0);
  setFillAfter(true);
  view.setAnimation(this);
  mView=new WeakReference<View>(view);
}
 

DisableChanger(InstalledAppDetails activity,ApplicationInfo info,int state){
  mPm=activity.mPm;
  mActivity=new WeakReference<InstalledAppDetails>(activity);
  mInfo=info;
  mState=state;
}
 

/** 
 * Constructs a new finalizer thread. 
 */
private Finalizer(Class<?> finalizableReferenceClass,Object frq){
  super(Finalizer.class.getName());
  this.finalizableReferenceClassReference=new WeakReference<Class<?>>(finalizableReferenceClass);
  this.frqReference=new PhantomReference<Object>(frq,queue);
  setDaemon(true);
  try {
    if (inheritableThreadLocals != null) {
      inheritableThreadLocals.set(this,null);
    }
  }
 catch (  Throwable t) {
    logger.log(Level.INFO,"Failed to clear thread local values inherited" + " by reference finalizer thread.",t);
  }
}
 

/** 
 * @param parentFile The current directory.
 * @param text The IconifiedText container.
 * @param imageView The ImageView from the IconifiedTextView.
 */
public void loadImage(String parentFile,IconifiedText text,ImageView imageView){
  if (!cancel && !mBlacklist.contains(text.getText())) {
    resetPurgeTimer();
    Bitmap bitmap=getBitmapFromCache(text.getText());
    if (bitmap != null) {
      imageView.setImageBitmap(bitmap);
      text.setIcon(bitmap);
    }
 else {
      if (!cancel) {
        Thumbnail thumbnail=new Thumbnail(parentFile,imageView,text);
        WeakReference<ThumbnailRunner> runner=new WeakReference<ThumbnailRunner>(new ThumbnailRunner(thumbnail));
        mExecutor.submit(runner.get());
      }
    }
  }
}
 

private static void setLatLngDetails(final View d,Activity context,ExifInterface exif){
  float[] latlng=new float[2];
  if (exif.getLatLong(latlng)) {
    setDetailsValue(d,String.valueOf(latlng[0]),R.id.details_latitude_value);
    setDetailsValue(d,String.valueOf(latlng[1]),R.id.details_longitude_value);
    if (latlng[0] == INVALID_LATLNG || latlng[1] == INVALID_LATLNG) {
      hideDetailsRow(d,R.id.details_latitude_row);
      hideDetailsRow(d,R.id.details_longitude_row);
      hideDetailsRow(d,R.id.details_location_row);
      return;
    }
    UpdateLocationCallback cb=new UpdateLocationCallback(new WeakReference<View>(d));
    Geocoder geocoder=new Geocoder(context);
    new ReverseGeocoderTask(geocoder,latlng,cb).execute();
  }
 else {
    hideDetailsRow(d,R.id.details_latitude_row);
    hideDetailsRow(d,R.id.details_longitude_row);
    hideDetailsRow(d,R.id.details_location_row);
  }
}
 

public void setObject(MediaObject object){
synchronized (Path.class) {
    Utils.assertTrue(mObject == null || mObject.get() == null);
    mObject=new WeakReference<MediaObject>(object);
  }
}
 

@Override protected Dialog onCreateDialog(int id,Bundle args){
  Context lightTheme=new ContextThemeWrapper(this,android.R.style.Theme_Light);
  if (id == DIALOG_ID_SELECT_ACTIVE_TAG) {
    SelectActiveTagDialog dialog=new SelectActiveTagDialog(lightTheme,mAdapter.getCursor());
    dialog.setInverseBackgroundForced(true);
    mSelectActiveTagDialog=new WeakReference<SelectActiveTagDialog>(dialog);
    return dialog;
  }
 else   if (id == DIALOG_ID_ADD_NEW_TAG) {
    ContentSelectorAdapter adapter=new ContentSelectorAdapter(lightTheme,SUPPORTED_TYPES);
    AlertDialog dialog=new AlertDialog.Builder(lightTheme).setTitle(R.string.select_type).setIcon(0).setNegativeButton(android.R.string.cancel,this).setAdapter(adapter,this).create();
    adapter.setListView(dialog.getListView());
    dialog.setInverseBackgroundForced(true);
    return dialog;
  }
  return super.onCreateDialog(id,args);
}
 

/** 
 * Called when something changes in our data set. Cleans up any weak references that are no longer valid along the way.
 */
private void notifyObservers(){
  final ArrayList<WeakReference<DataSetObserver>> observers=mObservers;
  final int count=observers.size();
  for (int i=count - 1; i >= 0; i--) {
    WeakReference<DataSetObserver> weak=observers.get(i);
    DataSetObserver obs=weak.get();
    if (obs != null) {
      obs.onChanged();
    }
 else {
      observers.remove(i);
    }
  }
}
 

/** 
 * @return the openConnection
 */
public MBeanServerConnection getConnection(){
  if (connection == null) {
    try {
      JMXConnector connector=JMXConnectorFactory.connect(getRemoteJMXURL(),null);
      connection=connector.getMBeanServerConnection();
      WeakReference<MBeanServerConnection> ref=new JMXConnectorReference(connection,connector);
      jmxConnectorRefs.add(ref);
    }
 catch (    IOException e) {
      throw new RuntimeException("Could not create remote JMX connection: " + this,e);
    }
  }
  return connection;
}
 

public DynamicIterator iterator(int index){
  DynamicIterator iterator=createIterator(index);
synchronized (lock) {
    for (Iterator<WeakReference<DynamicIterator>> it=iterators.iterator(); it.hasNext(); ) {
      if (it.next().get() == null) {
        it.remove();
      }
    }
    iterators.add(new WeakReference<DynamicIterator>(iterator));
  }
  return iterator;
}
 

/** 
 * Creates new form GotoLineDialog
 * @param text
 */
private GotoLineDialog(JTextComponent text){
  super(ActionUtils.getFrameFor(text),false);
  initComponents();
  this.text=new WeakReference<JTextComponent>(text);
  setLocationRelativeTo(text.getRootPane());
  getRootPane().setDefaultButton(jBtnOk);
  text.getDocument().putProperty(PROPERTY_KEY,this);
  SwingUtils.addEscapeListener(this);
}
 

/** 
 * Constructor. Clean the view and save the details of what we want.
 * @param queue
 * @param bookId
 * @param v
 * @param width
 * @param height
 */
public GetThumbnailTask(final String hash,final ImageView v,int maxWidth,int maxHeight,boolean cacheWasChecked){
  clearOldTaskFromView(v);
  mView=new WeakReference<ImageView>(v);
  mBookHash=hash;
  mCacheWasChecked=cacheWasChecked;
  mWidth=maxWidth;
  mHeight=maxHeight;
  v.setImageBitmap(null);
  ViewTagger.setTag(v,R.id.TAG_GET_THUMBNAIL_TASK,this);
}
 

public DynamicIterator iterator(int index){
  DynamicIterator iterator=createIterator(index);
synchronized (lock) {
    for (Iterator<WeakReference<DynamicIterator>> it=iterators.iterator(); it.hasNext(); ) {
      if (it.next().get() == null) {
        it.remove();
      }
    }
    iterators.add(new WeakReference<DynamicIterator>(iterator));
  }
  return iterator;
}
 

MemoryTile(RenderedImage owner,int tileX,int tileY,Raster tile,Object tileCacheMetric){
  this.owner=new WeakReference<RenderedImage>(owner);
  this.tile=tile;
  this.tileX=tileX;
  this.tileY=tileY;
  this.tileCacheMetric=tileCacheMetric;
  this.key=hashKey(owner,tileX,tileY);
  DataBuffer db=tile.getDataBuffer();
  this.tileSize=DataBuffer.getDataTypeSize(db.getDataType()) / 8L * db.getSize() * db.getNumBanks();
}
 

/** 
 * {@inheritDoc}
 */
public <T extends Enum<T> & ModelUpdate>void modelUpdated(final T... changed){
  final Set<WeakReference<Binding>> toRemove=Sets.newHashSet();
  for (  final WeakReference<Binding> weakBinding : bindings) {
    final Binding binding=weakBinding.get();
    if (binding != null) {
      binding.update(changed);
    }
 else {
      toRemove.add(weakBinding);
    }
  }
  if (!toRemove.isEmpty()) {
    bindings.removeAll(toRemove);
  }
}
 

@Override public Object getItem(final int position){
  final WeakReference<Bitmap> weakBitmapReference=bitmapMap.get(position);
  if (weakBitmapReference != null) {
    final Bitmap bitmap=weakBitmapReference.get();
    if (bitmap == null) {
      Log.v(TAG,"Empty bitmap reference at position: " + position + ":"+ this);
    }
 else {
      Log.v(TAG,"Reusing bitmap item at position: " + position + ":"+ this);
      return bitmap;
    }
  }
  Log.v(TAG,"Creating item at position: " + position + ":"+ this);
  final Bitmap bitmap=createBitmap(position);
  bitmapMap.put(position,new WeakReference<Bitmap>(bitmap));
  Log.v(TAG,"Created item at position: " + position + ":"+ this);
  return bitmap;
}
 

/** 
 * Purges the dictionary of loaded textures. Call this method if you receive the "Memory Warning" In the short term: it will free some resources preventing your app from being killed In the medium term: it will allocate more resources In the long term: it will be the same
 */
public void removeAllTextures(){
  for (  WeakReference<CCTexture2D> texSR : textures.values()) {
    CCTexture2D tex=texSR.get();
    if (tex != null)     tex.releaseTexture(CCDirector.gl);
  }
  textures.clear();
}
 

public DataBasePopupLogic(EventsBinder eventsBinder,DatabaseJTree databaseJTree,SQLSyntaxEditor sqlEditor) throws EventBinderException {
  weakDatabaseJTree=new WeakReference<DatabaseJTree>(databaseJTree);
  weakSqlEditor=new WeakReference<SQLSyntaxEditor>(sqlEditor);
  dataBasePopupGui=new DataBasePopupGui();
  eventsBinder.bind(this,dataBasePopupGui);
}
 

private AnimatorProxy(View view){
  setDuration(0);
  setFillAfter(true);
  view.setAnimation(this);
  mView=new WeakReference<View>(view);
}
 

/** 
 * Open a new SSH session using the given parameters.
 */
private TerminalBridge openConnection(HostBean host) throws IllegalArgumentException, IOException {
  if (getConnectedBridge(host) != null) {
    throw new IllegalArgumentException("Connection already open for that nickname");
  }
  TerminalBridge bridge=new TerminalBridge(this,host);
  bridge.setOnDisconnectedListener(this);
  bridge.startConnection();
synchronized (bridges) {
    bridges.add(bridge);
    WeakReference<TerminalBridge> wr=new WeakReference<TerminalBridge>(bridge);
    mHostBridgeMap.put(bridge.host,wr);
    mNicknameBridgeMap.put(bridge.host.getNickname(),wr);
  }
synchronized (disconnected) {
    disconnected.remove(bridge.host);
  }
  if (bridge.isUsingNetwork()) {
    connectivityManager.incRef();
  }
  if (prefs.getBoolean(PreferenceConstants.CONNECTION_PERSIST,true)) {
    connectionNotifier.showRunningNotification(this);
  }
  touchHost(host);
  return bridge;
}