01: /*
02: * ====================================================================
03: * Copyright (c) 2004-2008 TMate Software Ltd. All rights reserved.
04: *
05: * This software is licensed as described in the file COPYING, which
06: * you should have received as part of this distribution. The terms
07: * are also available at http://svnkit.com/license.html.
08: * If newer versions of this license are posted there, you may use a
09: * newer version instead, at your option.
10: * ====================================================================
11: */
12: package org.tmatesoft.svn.core.javahl;
13:
14: import java.lang.ref.Reference;
15: import java.lang.ref.ReferenceQueue;
16: import java.lang.ref.WeakReference;
17: import java.util.HashMap;
18: import java.util.Iterator;
19: import java.util.Map;
20:
21: /**
22: * @version 1.1.2
23: * @author TMate Software Ltd.
24: */
25: public class SVNClientImplTracker implements Runnable {
26:
27: private static ReferenceQueue ourQueue;
28: private static Map ourReferences = new HashMap();
29:
30: public static void registerClient(SVNClientImpl client) {
31: synchronized (SVNClientImplTracker.class) {
32: if (ourQueue == null) {
33: ourQueue = new ReferenceQueue();
34: new Thread(new SVNClientImplTracker()).start();
35: }
36: }
37: synchronized (ourReferences) {
38: WeakReference ref = new WeakReference(Thread
39: .currentThread(), ourQueue);
40: SVNClientImpl oldClient = (SVNClientImpl) ourReferences
41: .put(ref, client);
42: if (oldClient != null) {
43: oldClient.dispose();
44: }
45: }
46:
47: }
48:
49: public static void deregisterClient(SVNClientImpl impl) {
50: synchronized (ourReferences) {
51: for (Iterator clients = ourReferences.values().iterator(); clients
52: .hasNext();) {
53: // get all clients already registered from the current thread.
54: // but there could be a lot of them?
55: // call tracker on client dispose!
56: Object client = clients.next();
57: if (impl == client) {
58: clients.remove();
59: }
60: }
61: }
62: }
63:
64: public void run() {
65: while (true) {
66: Reference reference = null;
67: try {
68: reference = ourQueue.remove();
69: } catch (IllegalArgumentException e) {
70: } catch (InterruptedException e) {
71: }
72: if (reference == null) {
73: continue;
74: }
75: synchronized (ourReferences) {
76: SVNClientImpl oldClient = (SVNClientImpl) ourReferences
77: .remove(reference);
78: if (oldClient != null) {
79: oldClient.dispose();
80: }
81: }
82: }
83: }
84:
85: }
|