public class MainThread {
     static ExecutorService executorService = Executors.newFixedThreadPool(1);

     @SuppressWarnings(“rawtypes”)
     public static void main(String[] args) throws InterruptedException, ExecutionException {
          SubThread thread = new SubThread();
          Future future = executorService.submit(thread);
          executorService.shutdown();
          try {
            executorService.awaitTermination();
          } catch (Exception e) {
                   e.printStackTrace();
          }
          future.get();
     }
     public static class SubThread extends Thread{
          @Override
          public void run() {
              try {
                   sleep(5000L);
              } catch (InterruptedException e) {
                   e.printStackTrace();
              }
          }
     }     
}

public class MainThread {
    public static void main(String[] args) throws InterruptedException, ExecutionException {
          int threads = 5;
          final CountDownLatch countDownLatch = new CountDownLatch(threads);
          for(int i=0;i<threads;i++){
              SubThread thread = new SubThread(2000*(i+1), countDownLatch);
              thread.start();
          }
          countDownLatch.await();
     }
     public static class SubThread extends Thread{
          private CountDownLatch countDownLatch;
          private long work;          
          public SubThread(long work, CountDownLatch countDownLatch) {
              this.countDownLatch = countDownLatch;
              this.work = work;
          }

          @Override
          public void run() {
              try{
                sleep(work);
              }finally{
                   countDownLatch.countDown();
              }
              
          }
     }
}

public class MainThread {
    public static void main(String[] args) {
         SubThread thread = new SubThread();
         thread.start();
         System.out.println(“now waiting sub thread done.”);
         try {
             thread.join();
         } catch (InterruptedException e) {
             e.printStackTrace();
         }
         System.out.println(“now all done.”);
    }
    public static class SubThread extends Thread{
         @Override
         public void run() {
             try {
                  sleep(5000L);
             } catch (InterruptedException e) {
                  e.printStackTrace();
             }
         }     
    }
}

Set<Long> productIds = vendorItem2VendorItemSSharpeningtionDTOMap.values().stream().map(VendorItemSSharpeningtionDTO::getProductId).collect(Collectors.toSet());

Map<Long, ProductDto> productId2ProductDto = productList.stream().collect(toMap(ProductDto::getProductId, Function.identity()));

public class VendorItemSSharpeningtionDTO {
    private Long productId;

    public static Function<VendorItemSSharpeningtionDTO, Long> TO_PRODUCT_ID = VendorItemSSharpeningtionDTO::getProductId;
}

import org.joda.time.DateTimeComparator;
int result = DateTimeComparator.getDateOnlyInstance().compare(today, notifyDate);

package test;
import java.net.*;
import java.io.*; 

public class Server{
  private ServerSocket ss;
  private Socket socket;
  private BufferedReader in;
  private PrintWriter out;
 
 public Server() {
  try {
   ss=new ServerSocket(10000);
   while(true) {
    socket = ss.accept();
    String RemoteIP = socket.getInetAddress().getHostAddress();
    String RemotePort = ":"+socket.getLocalPort();
    System.out.println("A client come in!IP:"+RemoteIP+RemotePort);
    in = new BufferedReader(new InputStreamReader(socket.getInputStream()));
    String line = in.readLine();
    System.out.println("Cleint send is :" + line);
    out = new PrintWriter(socket.getOutputStream(),true);
    out.println("Your Message Received!");
    out.close();
    in.close();
    socket.close();
   }
  }catch (IOException e) {
   out.println("wrong");
  }
 }

 public static void main(String[] args) {
  new Server();
 }
}

package test;
import java.io.*;
import java.net.*; 

public class Client {
 Socket socket;
 BufferedReader in;
 PrintWriter out;
 public Client() {
  try {
   System.out.println("Try to Connect to 127.0.0.1:10000");
   socket = new Socket("127.0.0.1",10000);
   System.out.println("The Server Connected!");
   System.out.println("Please enter some Character:");
   BufferedReader line = new BufferedReader(new InputStreamReader(System.in));
   out = new PrintWriter(socket.getOutputStream(),true);
   out.println(line.readLine());
   in = new BufferedReader(new InputStreamReader(socket.getInputStream()));
   System.out.println(in.readLine());
   out.close();
   in.close();
   socket.close();
  }catch(IOException e) {
   out.println("Wrong");
  }
 }

 public static void main(String[] args) {
  new Client();
 }
}

// Remote Interface 接口的代码：

package Beans;
import javax.ejb.EJBObject;
import java.rmi.RemoteException;
public interface Add extends EJBObject {
  //some method declare 
}

// Home Interface 接口的代码：



package Beans;
import java.rmi.RemoteException;
import jaax.ejb.CreateException;
import javax.ejb.EJBHome;
public interface AddHome extends EJBHome {
  //some method declare
}

// EJB类的代码：

package Beans;
import java.rmi.RemoteException;
import javax.ejb.SessionBean;
import javx.ejb.SessionContext;
public class AddBean Implements SessionBean
{
  //some method declare
}