caozhao2017Java · caozhao2017Java · Jun 26, 2017 · Jun 26, 2017 · Jun 26, 2017 · Jun 26, 2017
diff --git a/.gitignore b/.gitignore
@@ -280,6 +280,22 @@ target
 liuxin/.DS_Store
 liuxin/src/.DS_Store
 
+students/1005475328/*
+students/1329920463/*
+students/1452302762/*
+students/14703250/*
+students/2842295913/*
+students/383117348/*
+students/404481481/*
+students/406400373/*
+students/549739951/*
+students/582161208/*
+students/592146505/*
+students/844620174/*
+students/87049319/*
+students/183549495/*
+
+
 
 
 

diff --git a/liuxin/data-structure/answer/src/main/java/com/coding/basic/tree/BinarySearchTreeTest.java b/liuxin/data-structure/answer/src/main/java/com/coding/basic/tree/BinarySearchTreeTest.java
@@ -104,5 +104,7 @@ public void testIsValid() {
 	public void testGetNodesBetween(){
 		List<Integer> numbers = this.tree.getNodesBetween(3,  8);
 		Assert.assertEquals("[3, 4, 5, 6, 8]",numbers.toString());
+		numbers = this.tree.getNodesBetween(1,  8);
+		Assert.assertEquals("[1, 2, 3, 4, 5, 6, 8]",numbers.toString());
 	}
 }
diff --git a/liuxin/knowledge-point/pom.xml b/liuxin/knowledge-point/pom.xml
@@ -0,0 +1,32 @@
+<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+  xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
+  <modelVersion>4.0.0</modelVersion>
+
+  <groupId>com.coderising</groupId>
+  <artifactId>knowledge-point</artifactId>
+  <version>0.0.1-SNAPSHOT</version>
+  <packaging>jar</packaging>
+
+  <name>knowledge-point</name>
+  <url>http://maven.apache.org</url>
+
+  <properties>
+    <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
+  </properties>
+
+  <dependencies>
+
+    <dependency>
+    	<groupId>junit</groupId>
+    	<artifactId>junit</artifactId>
+    	<version>4.12</version>
+    </dependency>
+
+  </dependencies>
+  <repositories>
+        <repository>
+            <id>aliyunmaven</id>
+            <url>http://maven.aliyun.com/nexus/content/groups/public/</url>
+        </repository>
+    </repositories>
+</project>
diff --git a/liuxin/knowledge-point/src/main/java/cas/CASSequence.java b/liuxin/knowledge-point/src/main/java/cas/CASSequence.java
@@ -0,0 +1,18 @@
+package cas;
+
+import java.util.concurrent.atomic.AtomicInteger;
+
+public class CASSequence{
+
+	private AtomicInteger count = new AtomicInteger(0);
+
+	public  int next(){
+		while(true){
+			int current = count.get();
+			int next = current +1;
+			if(count.compareAndSet(current, next)){
+				return next;
+			}
+		}		
+	}
+}
diff --git a/liuxin/knowledge-point/src/main/java/cas/NoBlockingStack.java b/liuxin/knowledge-point/src/main/java/cas/NoBlockingStack.java
@@ -0,0 +1,34 @@
+package cas;
+
+import java.util.concurrent.atomic.AtomicReference;
+
+public class NoBlockingStack<E> {
+	static class Node<E> {
+        final E item;
+        Node<E> next;
+        public Node(E item) { this.item = item; }
+    }
+
+    AtomicReference<Node<E>> head = new AtomicReference<Node<E>>();
+
+    public void push(E item) {
+        Node<E> newHead = new Node<E>(item);
+        Node<E> oldHead;
+        do {
+            oldHead = head.get();
+            newHead.next = oldHead;
+        } while (!head.compareAndSet(oldHead, newHead));
+    }
+    public E pop() {
+        Node<E> oldHead;
+        Node<E> newHead;
+        do {
+            oldHead = head.get();
+            if (oldHead == null) 
+                return null;
+            newHead = oldHead.next;
+        } while (!head.compareAndSet(oldHead,newHead));
+        return oldHead.item;
+    }
+
+}
diff --git a/liuxin/knowledge-point/src/main/java/cas/Sequence.java b/liuxin/knowledge-point/src/main/java/cas/Sequence.java
@@ -0,0 +1,11 @@
+package cas;
+
+public class Sequence{
+
+	private int value;
+
+	public int next(){
+		return value ++;
+	}
+
+}
diff --git a/liuxin/knowledge-point/src/main/java/threadlocal/Context.java b/liuxin/knowledge-point/src/main/java/threadlocal/Context.java
@@ -0,0 +1,20 @@
+package threadlocal;
+import java.util.HashMap;
+import java.util.Map;
+
+public class Context {
+
+	private static final ThreadLocal<String> txThreadLocal 
+		= new ThreadLocal<String>();
+
+	public static void setTransactionID(String txID) {		
+		txThreadLocal.set(txID); 
+
+	}
+
+	public static String getTransactionId() {
+		return txThreadLocal.get();
+	}	
+
+}
+
diff --git a/liuxin/knowledge-point/src/main/java/threadlocal/TransactionManager.java b/liuxin/knowledge-point/src/main/java/threadlocal/TransactionManager.java
@@ -0,0 +1,22 @@
+package threadlocal;
+
+public class TransactionManager {
+	private static final ThreadLocal<String> context = new ThreadLocal<String>();
+
+	public static void startTransaction() {
+		// logic to start a transaction
+		// ...
+		String txID = null;
+		context.set(txID);
+	}
+
+	public static String getTransactionId() {
+		return context.get();
+	}
+
+	public static void endTransaction() {
+		// logic to end a transaction
+		// …
+		context.remove();
+	}
+}
diff --git a/liuxin/knowledge-point/src/main/java/threadpool/BlockingQueue.java b/liuxin/knowledge-point/src/main/java/threadpool/BlockingQueue.java
@@ -0,0 +1,35 @@
+package threadpool;
+import java.util.LinkedList;
+import java.util.List;
+
+public class BlockingQueue {
+
+	private List queue = new LinkedList();
+	private int limit = 10;
+
+	public BlockingQueue(int limit) {
+		this.limit = limit;
+	}
+
+	public synchronized void enqueue(Object item) throws InterruptedException {
+		while (this.queue.size() == this.limit) {
+			wait();
+		}
+		if (this.queue.size() == 0) {
+			notifyAll();
+		}
+		this.queue.add(item);
+	}
+
+	public synchronized Object dequeue() throws InterruptedException {
+		while (this.queue.size() == 0) {
+			wait();
+		}
+		if (this.queue.size() == this.limit) {
+			notifyAll();
+		}
+
+		return this.queue.remove(0);
+	}
+
+}
diff --git a/liuxin/knowledge-point/src/main/java/threadpool/Task.java b/liuxin/knowledge-point/src/main/java/threadpool/Task.java
@@ -0,0 +1,5 @@
+package threadpool;
+
+public interface Task {
+	public void execute();
+}
diff --git a/liuxin/knowledge-point/src/main/java/threadpool/ThreadPool.java b/liuxin/knowledge-point/src/main/java/threadpool/ThreadPool.java
@@ -0,0 +1,37 @@
+package threadpool;
+import java.util.ArrayList;
+import java.util.List;
+
+
+public class ThreadPool {
+
+    private BlockingQueue taskQueue = null;
+    private List<WorkerThread> threads = new ArrayList<WorkerThread>();
+    private boolean isStopped = false;
+
+    public ThreadPool(int numOfThreads, int maxNumOfTasks){
+        taskQueue = new BlockingQueue(maxNumOfTasks);
+
+        for(int i=0; i<numOfThreads; i++){
+            threads.add(new WorkerThread(taskQueue));
+        }
+        for(WorkerThread thread : threads){
+            thread.start();
+        }
+    }
+
+    public synchronized void  execute(Task task) throws Exception{
+        if(this.isStopped) throw
+            new IllegalStateException("ThreadPool is stopped");
+
+        this.taskQueue.enqueue(task);
+    }
+
+    public synchronized void stop(){
+        this.isStopped = true;
+        for(WorkerThread thread : threads){
+           thread.doStop();
+        }
+    }
+
+}
diff --git a/liuxin/knowledge-point/src/main/java/threadpool/WorkerThread.java b/liuxin/knowledge-point/src/main/java/threadpool/WorkerThread.java
@@ -0,0 +1,33 @@
+package threadpool;
+
+
+public class WorkerThread extends Thread {
+
+    private BlockingQueue taskQueue = null;
+    private boolean       isStopped = false;
+
+    public WorkerThread(BlockingQueue queue){
+        taskQueue = queue;
+    }
+
+    public void run(){
+        while(!isStopped()){
+            try{
+                Task task = (Task) taskQueue.dequeue();
+                task.execute();
+            } catch(Exception e){
+                //log or otherwise report exception,
+                //but keep pool thread alive.
+            }
+        }
+    }
+
+    public synchronized void doStop(){
+        isStopped = true;
+        this.interrupt(); //break pool thread out of dequeue() call.
+    }
+
+    public synchronized boolean isStopped(){
+        return isStopped;
+    }
+}
diff --git a/liuxin/ood/ood-assignment/pom.xml b/liuxin/ood/ood-assignment/pom.xml
@@ -5,7 +5,19 @@
   <groupId>com.coderising</groupId>
   <artifactId>ood-assignment</artifactId>
   <version>0.0.1-SNAPSHOT</version>
-  <packaging>jar</packaging>
+    <build>
+        <plugins>
+            <plugin>
+                <groupId>org.apache.maven.plugins</groupId>
+                <artifactId>maven-compiler-plugin</artifactId>
+                <configuration>
+                    <source>1.7</source>
+                    <target>1.7</target>
+                </configuration>
+            </plugin>
+        </plugins>
+    </build>
+    <packaging>jar</packaging>
 
   <name>ood-assignment</name>
   <url>http://maven.apache.org</url>

diff --git a/liuxin/ood/ood-assignment/src/main/java/com/coderising/dp/bridge/GraphicLibrary1.java b/liuxin/ood/ood-assignment/src/main/java/com/coderising/dp/bridge/GraphicLibrary1.java
@@ -0,0 +1,11 @@
+package com.coderising.dp.bridge;
+
+public class GraphicLibrary1 {
+	public void draw_a_line(int x1,int y1,int x2,int y2){
+
+	}
+	public void draw_a_circle(int x,int y, int r){
+
+	}
+
+}
diff --git a/liuxin/ood/ood-assignment/src/main/java/com/coderising/dp/bridge/GraphicLibrary2.java b/liuxin/ood/ood-assignment/src/main/java/com/coderising/dp/bridge/GraphicLibrary2.java
@@ -0,0 +1,11 @@
+package com.coderising.dp.bridge;
+
+public class GraphicLibrary2 {
+	public void drawLine(int x1,int x2,int y1,int y2){
+
+	}
+	public void drawCircle(int x,int y, int r){
+
+	}
+
+}
diff --git a/liuxin/ood/ood-assignment/src/main/java/com/coderising/dp/builder/TagBuilder.java b/liuxin/ood/ood-assignment/src/main/java/com/coderising/dp/builder/TagBuilder.java
@@ -0,0 +1,37 @@
+package com.coderising.dp.builder;
+
+public class TagBuilder {
+	private TagNode rootNode;
+	private TagNode currentNode;
+	private TagNode parentNode;
+	public TagBuilder(String rootTagName){
+		rootNode = new TagNode(rootTagName);
+		currentNode = rootNode;
+		parentNode = null;
+	}
+
+	public TagBuilder addChild(String childTagName){
+		parentNode = this.currentNode;
+		this.currentNode = new TagNode(childTagName);
+		parentNode.add(currentNode);
+		return this;
+	}
+	public TagBuilder addSibling(String siblingTagName){
+
+		this.currentNode = new TagNode(siblingTagName);
+		parentNode.add(this.currentNode);
+		return this;
+
+	}
+	public TagBuilder setAttribute(String name, String value){
+		this.currentNode.setAttribute(name, value);
+		return this;
+	}
+	public TagBuilder setText(String value){
+		this.currentNode.setValue(value);
+		return this;
+	}
+	public String toXML(){
+		return this.rootNode.toXML();
+	}
+}