Merge pull request onlyliuxin#35 from MrWenGQ/master

Master

group22/1193590951/githubitem/src/com/github/mrwengq/first/LinkedList.java

@@ -73,7 +73,7 @@ public Object remove(int index) {
 		Node lastNode = null;
 		if (index + 1 <= size - 1)     //判断是否有下一位
 			nextNode = findNode(index + 1);
-		if (index - 1 > 0)			  //判断是否有上一位
+		if (index - 1 >= 0)			  //判断是否有上一位
 			lastNode = findNode(index - 1);
 		if (lastNode == null) {
 			head = nextNode;
@@ -172,46 +172,46 @@ public Object next() {
 	}
 
 	/**
-	 * 鎶婅閾捐〃閫嗙疆
-	 * 渚嬪閾捐〃涓�3->7->10 , 閫嗙疆鍚庡彉涓� 10->7->3
+	 * 把该链表逆置
+	 * 例如链表为 3->7->10 , 逆置后变为  10->7->3
 	 */
 	public  void reverse(){		
 
 	}
 
 	/**
-	 * 鍒犻櫎涓�釜鍗曢摼琛ㄧ殑鍓嶅崐閮ㄥ垎
-	 * 渚嬪锛歭ist = 2->5->7->8 , 鍒犻櫎浠ュ悗鐨勫�涓�7->8
-	 * 濡傛灉list = 2->5->7->8->10 ,鍒犻櫎浠ュ悗鐨勫�涓�,8,10
+	 * 删除一个单链表的前半部分
+	 * 例如：list = 2->5->7->8 , 删除以后的值为 7->8
+	 * 如果list = 2->5->7->8->10 ,删除以后的值为7,8,10
 
 	 */
 	public  void removeFirstHalf(){
 
 	}
 
 	/**
-	 * 浠庣i涓厓绱犲紑濮嬶紝 鍒犻櫎length 涓厓绱�锛�娉ㄦ剰i浠�寮�
+	 * 从第i个元素开始， 删除length 个元素 ， 注意i从0开始
 	 * @param i
 	 * @param length
 	 */
 	public  void remove(int i, int length){
 
 	}
 	/**
-	 * 鍋囧畾褰撳墠閾捐〃鍜宭ist鍧囧寘鍚凡鍗囧簭鎺掑垪鐨勬暣鏁�
-	 * 浠庡綋鍓嶉摼琛ㄤ腑鍙栧嚭閭ｄ簺list鎵�寚瀹氱殑鍏冪礌
-	 * 渚嬪褰撳墠閾捐〃 = 11->101->201->301->401->501->601->701
+	 * 假定当前链表和list均包含已升序排列的整数
+	 * 从当前链表中取出那些list所指定的元素
+	 * 例如当前链表 = 11->101->201->301->401->501->601->701
 	 * listB = 1->3->4->6
-	 * 杩斿洖鐨勭粨鏋滃簲璇ユ槸[101,301,401,601]  
+	 * 返回的结果应该是[101,301,401,601]  
 	 * @param list
 	 */
 	public static int[] getElements(LinkedList list){
 		return null;
 	}
 
 	/**
-	 * 宸茬煡閾捐〃涓殑鍏冪礌浠ュ�閫掑鏈夊簭鎺掑垪锛屽苟浠ュ崟閾捐〃浣滃瓨鍌ㄧ粨鏋勩�
-	 * 浠庡綋鍓嶉摼琛ㄤ腑涓垹闄ゅ湪list涓嚭鐜扮殑鍏冪礌 
+	 * 已知链表中的元素以值递增有序排列，并以单链表作存储结构。
+	 * 从当前链表中中删除在list中出现的元素 
 
 	 * @param list
 	 */
@@ -221,16 +221,16 @@ public  void subtract(LinkedList list){
 	}
 
 	/**
-	 * 宸茬煡褰撳墠閾捐〃涓殑鍏冪礌浠ュ�閫掑鏈夊簭鎺掑垪锛屽苟浠ュ崟閾捐〃浣滃瓨鍌ㄧ粨鏋勩�
-	 * 鍒犻櫎琛ㄤ腑鎵�湁鍊肩浉鍚岀殑澶氫綑鍏冪礌锛堜娇寰楁搷浣滃悗鐨勭嚎鎬ц〃涓墍鏈夊厓绱犵殑鍊煎潎涓嶇浉鍚岋級
+	 * 已知当前链表中的元素以值递增有序排列，并以单链表作存储结构。
+	 * 删除表中所有值相同的多余元素（使得操作后的线性表中所有元素的值均不相同）
 	 */
 	public  void removeDuplicateValues(){
 
 	}
 
 	/**
-	 * 宸茬煡閾捐〃涓殑鍏冪礌浠ュ�閫掑鏈夊簭鎺掑垪锛屽苟浠ュ崟閾捐〃浣滃瓨鍌ㄧ粨鏋勩�
-	 * 璇曞啓涓�珮鏁堢殑绠楁硶锛屽垹闄よ〃涓墍鏈夊�澶т簬min涓斿皬浜巑ax鐨勫厓绱狅紙鑻ヨ〃涓瓨鍦ㄨ繖鏍风殑鍏冪礌锛�
+	 * 已知链表中的元素以值递增有序排列，并以单链表作存储结构。
+	 * 试写一高效的算法，删除表中所有值大于min且小于max的元素（若表中存在这样的元素）
 	 * @param min
 	 * @param max
 	 */
@@ -239,12 +239,11 @@ public  void removeRange(int min, int max){
 	}
 
 	/**
-	 * 鍋囪褰撳墠閾捐〃鍜屽弬鏁發ist鎸囧畾鐨勯摼琛ㄥ潎浠ュ厓绱犱緷鍊奸�澧炴湁搴忔帓鍒楋紙鍚屼竴琛ㄤ腑鐨勫厓绱犲�鍚勪笉鐩稿悓锛�
-	 * 鐜拌姹傜敓鎴愭柊閾捐〃C锛屽叾鍏冪礌涓哄綋鍓嶉摼琛ㄥ拰list涓厓绱犵殑浜ら泦锛屼笖琛–涓殑鍏冪礌鏈変緷鍊奸�澧炴湁搴忔帓鍒�
+	 * 假设当前链表和参数list指定的链表均以元素依值递增有序排列（同一表中的元素值各不相同）
+	 * 现要求生成新链表C，其元素为当前链表和list中元素的交集，且表C中的元素有依值递增有序排列
 	 * @param list
 	 */
 	public  LinkedList intersection( LinkedList list){
 		return null;
 	}
-
 }

group22/1193590951/githubitem/src/com/github/mrwengq/first/LinkedListTest.java

@@ -65,7 +65,7 @@ public void testGet() {
 
 	@Test
 	public void testRemoveInt() {
-		LinkedList li = new LinkedList();
+		/*LinkedList li = new LinkedList();
 		li.add("1");
 		li.add("2");
 		li.add("3");
@@ -75,8 +75,23 @@ public void testRemoveInt() {
 		assertEquals(li.get(0), "1");
 		assertEquals(li.get(1), "2");
 		assertEquals(li.get(2), "3");
-		assertEquals(li.get(3), "5");
+		assertEquals(li.get(3), "5");*/
+		LinkedList ll = new LinkedList();
+		ll.add(11);
+		ll.add(101);
+		ll.add(201);
+		ll.add(301);
+		ll.add(401);
+		ll.add(501);
+		ll.add(601);
+		ll.add(701);
+		ll.remove(0);
+		ll.remove(1);
+		//ll.remove(3);
+		//ll.remove(4);
+		System.out.println(ll.get(0)+" "+ll.get(1)+" "+ll.get(2)+" "+ll.get(3));
 
+
 	}
 
 	@Test

group22/1193590951/githubitem/src/com/github/mrwengq/tid/DownloadThread.java

@@ -0,0 +1,43 @@
+package com.github.mrwengq.tid;
+
+import java.io.File;
+import java.io.IOException;
+import java.io.RandomAccessFile;
+import java.util.concurrent.CyclicBarrier;
+
+import com.github.mrwengq.tid.api.Connection;
+
+public class DownloadThread extends Thread{
+
+	Connection conn;
+	int startPos;
+	int endPos;
+	String fileName;
+	CyclicBarrier  cb;
+
+	public DownloadThread( Connection conn, String fileName ,int startPos, int endPos,CyclicBarrier cb){
+
+		this.conn = conn;		
+		this.fileName = fileName;
+		this.startPos = startPos;
+		this.endPos = endPos;
+		this.cb = cb;
+	}
+	public void run(){
+		byte[] b = null;
+		try {
+			 b  = conn.read(startPos,endPos);
+			 RandomAccessFile raf = new RandomAccessFile(fileName, "rw");
+			 raf.seek(startPos);
+			 raf.write(b);
+			 raf.close();
+			 conn.close();
+			 cb.await();
+
+		} catch (Exception e) {
+			e.printStackTrace();
+		}
+
+	}
+
+}

group22/1193590951/githubitem/src/com/github/mrwengq/tid/FileDownloader.java

@@ -0,0 +1,129 @@
+package com.github.mrwengq.tid;
+
+import java.io.FileNotFoundException;
+import java.io.RandomAccessFile;
+import java.util.concurrent.CyclicBarrier;
+
+import com.github.mrwengq.tid.api.Connection;
+import com.github.mrwengq.tid.api.ConnectionException;
+import com.github.mrwengq.tid.api.ConnectionManager;
+import com.github.mrwengq.tid.api.DownloadListener;
+
+
+public class FileDownloader {
+
+	String url;
+
+	DownloadListener listener;
+
+	ConnectionManager cm;
+
+	String fileName;
+
+	public FileDownloader(String _url,String fileName) {
+		this.url = _url;
+		this.fileName = fileName;
+
+	}
+
+	public void execute(){
+		// 在这里实现你的代码， 注意： 需要用多线程实现下载
+		// 这个类依赖于其他几个接口, 你需要写这几个接口的实现代码
+		// (1) ConnectionManager , 可以打开一个连接，通过Connection可以读取其中的一段（用startPos, endPos来指定）
+		// (2) DownloadListener, 由于是多线程下载， 调用这个类的客户端不知道什么时候结束，所以你需要实现当所有
+		//     线程都执行完以后， 调用listener的notifiedFinished方法， 这样客户端就能收到通知。
+		// 具体的实现思路：
+		// 1. 需要调用ConnectionManager的open方法打开连接， 然后通过Connection.getContentLength方法获得文件的长度
+		// 2. 至少启动3个线程下载，  注意每个线程需要先调用ConnectionManager的open方法
+		// 然后调用read方法， read方法中有读取文件的开始位置和结束位置的参数， 返回值是byte[]数组
+		// 3. 把byte数组写入到文件中
+		// 4. 所有的线程都下载完成以后， 需要调用listener的notifiedFinished方法
+
+		// 下面的代码是示例代码， 也就是说只有一个线程， 你需要改造成多线程的。
+		Connection conn = null;
+
+		CyclicBarrier cb = new CyclicBarrier(3, new Runnable() {
+
+			@Override
+			public void run() {
+				listener.notifyFinished();
+
+			}
+		});
+		try {
+
+			conn =  cm.open(this.url);
+
+			int length = conn.getContentLength();
+			System.out.println(length);
+			createFile(length); //创建占位文件
+
+			int size = length/3;
+			int pyl = (length - (length%3))/3;
+
+			if(length<3){
+
+				cb = new CyclicBarrier(3, new Runnable() {	
+					@Override
+					public void run() {
+						listener.notifyFinished();
+					}
+				});
+				new DownloadThread(conn,fileName,0,length-1,cb).start();
+
+
+			}else{
+
+					for(int i =0;i<3;i++){
+						if(2==i){
+							new DownloadThread(conn,fileName, i*size, (i+1)*size+length%3-1,cb).start();
+							System.out.println("第i线程"+i+"起始"+i*size+"-结束"+(i*size+length%3-1));
+							break;
+						}
+
+						new DownloadThread(conn,fileName,i*size,(i+1)*size-1,cb).start();
+						System.out.println("第i线程"+i+"起始"+i*size+"-结束"+((i+1)*size-1));
+					}
+
+			}			
+		} catch (ConnectionException e) {			
+			e.printStackTrace();
+		}finally{
+			if(conn != null){
+				conn.close();
+			}
+		}
+
+
+
+
+	}
+
+	public void setListener(DownloadListener listener) {
+		this.listener = listener;
+	}
+
+
+
+	public void setConnectionManager(ConnectionManager ucm){
+		this.cm = ucm;
+	}
+
+	public DownloadListener getListener(){
+		return this.listener;
+	}
+	private void createFile( int length){
+		try {
+			RandomAccessFile raf  =  new RandomAccessFile(fileName,"rw");
+			while(length>0){
+				raf.write(0);
+				length --;
+			}
+
+		} catch (Exception e) {
+			// TODO Auto-generated catch block
+			e.printStackTrace();
+		}
+
+	}
+}

group22/1193590951/githubitem/src/com/github/mrwengq/tid/FileDownloaderTest.java

@@ -0,0 +1,60 @@
+package com.github.mrwengq.tid;
+
+import org.junit.After; 
+import org.junit.Before;
+import org.junit.Test;
+
+import com.github.mrwengq.tid.api.ConnectionManager;
+import com.github.mrwengq.tid.api.DownloadListener;
+import com.github.mrwengq.tid.impl.ConnectionManagerImpl;
+
+public class FileDownloaderTest {
+	boolean downloadFinished = false;
+	@Before
+	public void setUp() throws Exception {
+	}
+
+	@After
+	public void tearDown() throws Exception {
+	}
+
+	@Test
+	public void testDownload() {
+
+		//String url = "http://localhost:8080/test.jpg";
+		String url = "http://www.hinews.cn/pic/0/13/91/26/13912621_821796.jpg";
+		String fileName = "C:\\Users\\Administrator\\Desktop\\个人文档\\test.jpg";
+		FileDownloader downloader = new FileDownloader(url,fileName);
+
+
+		ConnectionManager cm = new ConnectionManagerImpl();
+		downloader.setConnectionManager(cm);
+
+		downloader.setListener(new DownloadListener() {
+			@Override
+			public void notifyFinished() {
+				downloadFinished = true;
+			}
+
+		});
+
+
+		downloader.execute();
+
+		// 等待多线程下载程序执行完毕
+		while (!downloadFinished) {
+			try {
+				System.out.println("还没有下载完成，休眠五秒");
+				//休眠5秒
+				Thread.sleep(5000);
+			} catch (InterruptedException e) {				
+				e.printStackTrace();
+			}
+		}
+		System.out.println("下载完成！");
+
+
+
+	}
+
+}

group22/1193590951/githubitem/src/com/github/mrwengq/tid/api/Connection.java

@@ -0,0 +1,23 @@
+package com.github.mrwengq.tid.api;
+
+import java.io.IOException;
+
+public interface Connection {
+	/**
+	 * 给定开始和结束位置， 读取数据， 返回值是字节数组
+	 * @param startPos 开始位置， 从0开始
+	 * @param endPos 结束位置
+	 * @return
+	 */
+	public byte[] read(int startPos,int endPos) throws IOException;
+	/**
+	 * 得到数据内容的长度
+	 * @return
+	 */
+	public int getContentLength();
+
+	/**
+	 * 关闭连接
+	 */
+	public void close();
+}