From a982f8b2df4720b75579b51ea78252608e4d95e6 Mon Sep 17 00:00:00 2001
From: cheney <cbed@163.com>
Date: Fri, 15 Jul 2022 10:19:58 +0800
Subject: [PATCH] =?UTF-8?q?=E5=A4=9A=E7=BA=BF=E7=A8=8B=E5=AE=89=E5=85=A8?=
 =?UTF-8?q?=E7=9A=84=E6=8E=A5=E5=8F=A3?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../java/com/sunyard/MutiThreadHander.java    | 109 ++++++++++++++++++
 1 file changed, 109 insertions(+)
 create mode 100644 src/main/java/com/sunyard/MutiThreadHander.java

diff --git a/src/main/java/com/sunyard/MutiThreadHander.java b/src/main/java/com/sunyard/MutiThreadHander.java
new file mode 100644
index 0000000..6b11ad8
--- /dev/null
+++ b/src/main/java/com/sunyard/MutiThreadHander.java
@@ -0,0 +1,109 @@
+package com.sunyard;
+
+import java.util.HashMap;
+import java.util.Iterator;
+import java.util.Map;
+import java.util.concurrent.Executors;
+import java.util.concurrent.ScheduledExecutorService;
+import java.util.concurrent.TimeUnit;
+
+/**
+ * 管理多线程间对象
+ * 类似 ThreadLocal
+ * @param <T>
+ */
+public class MutiThreadHander<T> {
+
+    private static class Handler<T> {
+        private T obj = null;
+        private long creatAt = System.currentTimeMillis();
+        private long lastGetAt = System.currentTimeMillis();
+
+        public Handler(T obj) {
+            this.obj = obj;
+        }
+
+        public T getObj() {
+            return obj;
+        }
+
+        public long getCreatAt() {
+            return creatAt;
+        }
+
+        public long getLastGetAt() {
+            return lastGetAt;
+        }
+    }
+    private final Map<Thread, Handler> handers = new HashMap<Thread, Handler>();
+    private ScheduledExecutorService gcThread = Executors.newScheduledThreadPool(1);
+
+    private long maxLiveMillis = 8 * 3600 * 1000;
+    private long maxIdleMillis = 3600 * 1000;
+    private long checkEveryMillis = 5 * 60 * 1000;
+
+    public MutiThreadHander() {
+        gcThread.scheduleWithFixedDelay(new Runnable() {
+            @Override
+            public void run() {
+                try {
+                    if ( handers.size() <= 0 ) {
+                        return;
+                    }
+
+                    long now = System.currentTimeMillis();
+                    Iterator<Map.Entry<Thread, Handler>>it = handers.entrySet().iterator();
+                    while ( it.hasNext() ){
+                        Map.Entry<Thread, Handler> entry = it.next();
+
+                        // check maxLiveMillis
+                        if ( entry.getValue().getCreatAt() - now > maxLiveMillis ){
+                            synchronized ( handers ){
+                                it.remove();
+                            }
+                        }
+
+                        // check maxIdleMillis
+                        if ( entry.getValue().getLastGetAt() - now > maxIdleMillis ){
+                            synchronized ( handers ){
+                                it.remove();
+                            }
+                        }
+                    }
+                } catch ( Exception e) {
+                    e.printStackTrace();
+                }
+            }
+        }, checkEveryMillis, checkEveryMillis, TimeUnit.MILLISECONDS );
+    }
+
+
+
+    protected T initialValue() {
+        return null;
+    }
+
+    public void clear(){
+        synchronized ( handers ) {
+            handers.remove( Thread.currentThread() );
+        }
+    }
+
+    public void set(T obj){
+        synchronized ( handers ) {
+            handers.put( Thread.currentThread() , new Handler(obj));
+        }
+    }
+
+    public T get(){
+        synchronized ( handers ) {
+            Handler hander = handers.get( Thread.currentThread() );
+            if ( null == hander ) {
+                T o = initialValue();
+                hander = new Handler( o );
+                handers.put( Thread.currentThread(), hander );
+            }
+            return (T) hander.getObj();
+        }
+    }
+}