线程相关的设计模式

Author: sean417

HighConcurreny/src/main/java/DesignPattern/future/Client.java

@@ -0,0 +1,32 @@
+package DesignPattern.future;
+
+import jdk2.ThreadPool;
+
+/**
+ * Created by chenyang on 2017/3/25.
+ */
+public class Client {
+    public Data request(final String queryStr){
+        final FutureData future=new FutureData();
+        new Thread(){
+            public void run(){
+                RealData realData=new RealData(queryStr);
+                future.setRealData(realData);
+            }
+        }.start();
+        return future;
+    }
+
+    public static void main(String[] args) {
+        Client client=new Client();
+
+        Data data=client.request("name");
+        System.out.println("请求完毕");
+        try {
+            Thread.sleep(50);
+        }catch (InterruptedException e){
+
+        }
+        System.out.println("数据="+data.getResult());
+    }
+}

HighConcurreny/src/main/java/DesignPattern/future/Data.java

@@ -0,0 +1,8 @@
+package DesignPattern.future;
+
+/**
+ * Created by chenyang on 2017/3/25.
+ */
+public interface Data {
+    public String getResult();
+}

HighConcurreny/src/main/java/DesignPattern/future/FutureData.java

@@ -0,0 +1,30 @@
+package DesignPattern.future;
+
+/**
+ * Created by chenyang on 2017/3/25.
+ */
+public class FutureData implements Data {
+    protected RealData realData=null;
+    protected boolean isReady=false;
+
+    public synchronized void setRealData(RealData realdata){
+        if(isReady){
+            return;
+        }
+        this.realData=realdata;
+        isReady=true;
+        notifyAll();
+    }
+
+    @Override
+    public synchronized String getResult() {
+        while (!isReady){
+            try {
+                wait();
+            }catch (InterruptedException e){
+
+            }
+        }
+        return realData.result;
+    }
+}

HighConcurreny/src/main/java/DesignPattern/future/RealData.java

@@ -0,0 +1,28 @@
+package DesignPattern.future;
+
+/**
+ * Created by chenyang on 2017/3/25.
+ */
+public class RealData implements Data {
+    protected final String result;
+
+    public RealData(String para) {
+        //RealData的构造可能很慢，需要用户等待很久，这里使用sleep模式。
+        StringBuilder sb=new StringBuilder();
+        for(int i=0;i<10;i++){
+            sb.append(para);
+            try {
+                //这里使用sleep,代替一个很慢的操作过程。
+                Thread.sleep(100);
+            }catch (InterruptedException e){
+
+            }
+        }
+        result=sb.toString();
+    }
+
+    @Override
+    public String getResult() {
+        return result;
+    }
+}

HighConcurreny/src/main/java/DesignPattern/jdkFuture/FutureMain.java

@@ -0,0 +1,28 @@
+package DesignPattern.jdkFuture;
+
+import java.util.concurrent.ExecutionException;
+import java.util.concurrent.ExecutorService;
+import java.util.concurrent.Executors;
+import java.util.concurrent.FutureTask;
+
+/**
+ * Created by chenyang on 2017/3/26.
+ */
+public class FutureMain {
+    public static void main(String[] args) throws Exception{
+        FutureTask<String> future=new FutureTask<String>(new RealData("a"));
+        ExecutorService executor= Executors.newFixedThreadPool(1);
+
+        executor.submit(future);
+
+        System.out.println("请求完毕");
+
+        try {
+            Thread.sleep(2000);
+        }catch (InterruptedException ex){
+
+        }
+
+        System.out.println("数据="+future.get());
+    }
+}

HighConcurreny/src/main/java/DesignPattern/jdkFuture/FutureMain2.java

@@ -0,0 +1,27 @@
+package DesignPattern.jdkFuture;
+
+import java.util.concurrent.ExecutorService;
+import java.util.concurrent.Executors;
+import java.util.concurrent.Future;
+import java.util.concurrent.FutureTask;
+
+/**
+ * Created by chenyang on 2017/3/26.
+ */
+public class FutureMain2 {
+    public static void main(String[] args) throws Exception{
+        ExecutorService executor= Executors.newFixedThreadPool(1);
+        Future<String> future=executor.submit(new RealData("a"));
+
+        System.out.println("请求完毕");
+        System.out.println(        future.isDone());
+        try {
+            Thread.sleep(2000);
+        }catch (InterruptedException ex){
+
+        }
+        System.out.println("数据="+future.get());
+        System.out.println(future.isDone());
+
+    }
+}

HighConcurreny/src/main/java/DesignPattern/jdkFuture/RealData.java

@@ -0,0 +1,28 @@
+package DesignPattern.jdkFuture;
+
+import java.util.concurrent.Callable;
+
+/**
+ * Created by chenyang on 2017/3/26.
+ */
+public class RealData implements Callable<String> {
+    private String para;
+
+    public RealData(String para) {
+        this.para = para;
+    }
+
+    @Override
+    public String call() throws Exception {
+        StringBuilder sb=new StringBuilder();
+        for(int i=0;i<10;i++){
+            sb.append(para);
+            try {
+                Thread.sleep(100);
+            }catch (InterruptedException e){
+
+            }
+        }
+        return sb.toString();
+    }
+}

HighConcurreny/src/main/java/DesignPattern/socket/MultiThreadEchoClient.java

@@ -0,0 +1,51 @@
+package DesignPattern.socket;
+
+import java.io.*;
+import java.net.InetSocketAddress;
+import java.net.Socket;
+import java.net.UnknownHostException;
+
+/**
+ * Created by chenyang on 2017/3/26.
+ */
+public class MultiThreadEchoClient {
+
+    public static void main(String[] args) {
+        Socket client=null;
+        PrintWriter writer=null;
+        BufferedReader reader=null;
+        try {
+            client=new Socket();
+            client.connect(new InetSocketAddress("localhost",8000));
+            writer=new PrintWriter(client.getOutputStream(),true);
+            writer.println("hello"+System.currentTimeMillis());
+            writer.flush();
+            System.out.println(System.currentTimeMillis());
+            reader=new BufferedReader(new InputStreamReader(client.getInputStream()));
+            System.out.println(System.currentTimeMillis()+"from server:"+reader.readLine());
+        }catch (UnknownHostException ex){
+            ex.printStackTrace();
+        }catch (IOException e){
+            e.printStackTrace();
+        } finally {
+            if(writer!=null){
+                writer.close();
+            }
+            if(reader!=null){
+                try {
+                    reader.close();
+                }catch (IOException ex){
+                    ex.printStackTrace();
+                }
+
+            }
+            if(client!=null){
+                try {
+                    client.close();
+                }catch (IOException ex){
+                    ex.printStackTrace();
+                }
+            }
+        }
+    }
+}

HighConcurreny/src/main/java/DesignPattern/socket/MultiThreadEchoServer.java

@@ -0,0 +1,72 @@
+package DesignPattern.socket;
+
+import java.io.BufferedReader;
+import java.io.IOException;
+import java.io.InputStreamReader;
+import java.io.PrintWriter;
+import java.net.ServerSocket;
+import java.net.Socket;
+import java.util.concurrent.ExecutorService;
+import java.util.concurrent.Executors;
+
+/**
+ * 常规的socket服务端，服务器端采用一个线程接受一个客户端来处理。
+ * Created by chenyang on 2017/3/26.
+ */
+public class MultiThreadEchoServer {
+    private static ExecutorService tp= Executors.newCachedThreadPool();
+    static class HandleMsg implements Runnable{
+        Socket clientSocket;
+
+        public HandleMsg(Socket clientSocket) {
+            this.clientSocket = clientSocket;
+        }
+
+        @Override
+        public void run() {
+            BufferedReader is=null;
+            PrintWriter os=null;
+            try {
+                is=new BufferedReader(new InputStreamReader(clientSocket.getInputStream()));
+                os=new PrintWriter(clientSocket.getOutputStream(),true);
+                //从InputStream当中读取客户端所发送的数据
+                String inputLine=null;
+                long b=System.currentTimeMillis();
+                while ((inputLine=is.readLine())!=null){
+                    os.println(inputLine);
+                }
+                long e=System.currentTimeMillis();
+                System.out.println("spend:"+(e-b)+"ms");
+            }catch (IOException e){
+                e.printStackTrace();
+            }finally {
+                try {
+                    if(is!=null) is.close();
+                    if(os!=null) os.close();
+                    clientSocket.close();
+                }catch (IOException ex){
+                    ex.printStackTrace();
+                }
+            }
+        }
+    }
+
+    public static void main(String[] args) {
+        ServerSocket echoServer=null;
+        Socket clientSocket=null;
+        try {
+            echoServer=new ServerSocket(8000);
+        }catch (IOException e){
+            System.out.println(e);
+        }
+        while (true){
+            try {
+                clientSocket =echoServer.accept();
+                System.out.println(clientSocket.getRemoteSocketAddress()+" connect!"+System.currentTimeMillis());
+                tp.execute(new HandleMsg(clientSocket));
+            }catch (IOException e){
+                System.out.println(e);
+            }
+        }
+    }
+}

HighConcurreny/src/main/java/ParallelBasic/SimpleWN.java

@@ -16,6 +16,15 @@ public class SimpleWN {
     public static class T1 extends Thread{
         @Override
         public void run() {
+            //加上这句虽然造成T1一直等待，但是其他线程可以调用同步方法，因为T1已经释放了锁资源
+//            try {
+//
+//
+//                sleep(100);
+//            }catch (InterruptedException ex){
+//
+//            }
+
             synchronized (object){
                 System.out.println(System.currentTimeMillis()+":T1 start!");
                 try {