From 6ea2518ee498c54eee132d87c8d77909bb9b307f Mon Sep 17 00:00:00 2001
From: wanglihui <949764788@qq.com>
Date: Fri, 7 Aug 2020 10:07:52 +0800
Subject: [PATCH] =?UTF-8?q?IP=20Learning=20tsg=E9=A1=B9=E7=9B=AE=20spark?=
 =?UTF-8?q?=E7=89=88=E6=9C=AC=E9=A6=96=E6=AC=A1=E6=8F=90=E4=BA=A4?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../ac/iie/service/update/UpdateDocument.scala |  4 ++++
 .../test/scala/cn/ac/iie/test/threadTest.java  | 18 ++++++++++++++++++
 2 files changed, 22 insertions(+)
 create mode 100644 ip-learning-spark/src/test/scala/cn/ac/iie/test/threadTest.java

diff --git a/ip-learning-spark/src/main/scala/cn/ac/iie/service/update/UpdateDocument.scala b/ip-learning-spark/src/main/scala/cn/ac/iie/service/update/UpdateDocument.scala
index b5f875f..038e301 100644
--- a/ip-learning-spark/src/main/scala/cn/ac/iie/service/update/UpdateDocument.scala
+++ b/ip-learning-spark/src/main/scala/cn/ac/iie/service/update/UpdateDocument.scala
@@ -22,6 +22,10 @@ object UpdateDocument {
   private val LOG = LoggerFactory.getLogger(UpdateDocument.getClass)
   private val baseArangoData = new BaseArangoData()
 
+  def updateDocument(): Unit ={
+
+  }
+
   def updateVertexFqdn(): Unit ={
     baseArangoData.readHistoryData("FQDN",historyVertexFqdnMap,classOf[BaseDocument])
     val hisVerFqdnBc = spark.sparkContext.broadcast(historyVertexFqdnMap)
diff --git a/ip-learning-spark/src/test/scala/cn/ac/iie/test/threadTest.java b/ip-learning-spark/src/test/scala/cn/ac/iie/test/threadTest.java
new file mode 100644
index 0000000..912f4a2
--- /dev/null
+++ b/ip-learning-spark/src/test/scala/cn/ac/iie/test/threadTest.java
@@ -0,0 +1,18 @@
+package cn.ac.iie.test;
+
+public class threadTest implements Runnable {
+    private int count = 10;
+    @Override
+    public /*synchronized*/ void run() {
+        count--;
+        System.out.println(Thread.currentThread().getName() + " count = " + count);
+    }
+
+    public static void main(String[] args) {
+        threadTest t = new threadTest();
+        for(int i=0; i<5; i++) {
+            new Thread(t, "THREAD" + i).start();
+        }
+    }
+
+}