EasyPost Java Threading Example

ThreadTest.java

package com.easypost;

import com.easypost.model.*;
import org.junit.BeforeClass;
import org.junit.Test;
import org.junit.Rule;
import org.junit.rules.ExpectedException;

import java.text.ParseException;
import java.util.HashMap;
import java.util.Map;
import java.util.List;
import java.util.ArrayList;
import java.util.Date;
import java.text.DateFormat;
import java.text.SimpleDateFormat;

import java.lang.InterruptedException;

import com.easypost.exception.EasyPostException;

import static org.junit.Assert.*;

public class ThreadTest {
  static Map<String, Object> defaultFromAddress = new HashMap<String, Object>();
  static Map<String, Object> defaultToAddress = new HashMap<String, Object>();
  static Map<String, Object> defaultParcel = new HashMap<String, Object>();

  static Map<String, Object> orderShipment() throws EasyPostException {
    Map<String, Object> shipmentMap = new HashMap<String, Object>();
    shipmentMap.put("parcel", defaultParcel);
    return shipmentMap;
  }

  @BeforeClass
  public static void setUp() {
    EasyPost.apiKey = "cueqNZUb3ldeWTNX7MU3Mel8UXtaAMUi";

    defaultFromAddress.put("name", "EasyPost");
    defaultFromAddress.put("street1", "164 Townsend St");
    defaultFromAddress.put("street2", "Unit 1");
    defaultFromAddress.put("city", "San Francisco");
    defaultFromAddress.put("state", "CA");
    defaultFromAddress.put("zip", "94107");
    defaultFromAddress.put("phone", "415-456-7890");

    defaultToAddress.put("company", "Airport Shipping");
    defaultToAddress.put("street1", "601 Brasilia Avenue");
    defaultToAddress.put("city", "Kansas City");
    defaultToAddress.put("state", "MO");
    defaultToAddress.put("zip", "64153");
    defaultToAddress.put("phone", "314-924-0383");

    defaultParcel.put("length", 10.8);
    defaultParcel.put("width", 8.3);
    defaultParcel.put("height", 6);
    defaultParcel.put("weight", 10);
  }

  private static class CreateOrders implements Runnable {
    List<Map<String, Object>> orders;

    public CreateOrders(List<Map<String, Object>> orders) {
      this.orders = orders;
    }

    public void run() {
      try {
        for (int i = 0; i < this.orders.size(); i++) {
          System.out.format("Thread %s: starting order creation...%n",
            Thread.currentThread().getName());

          Order order = Order.create(this.orders.get(i));
          // save order id to database or buy now

          System.out.format("Thread %s: created order %s%n",
            Thread.currentThread().getName(),
            order.getId());
        }
      } catch(EasyPostException e) {
        System.out.println("EasyPost Exception caught creating order.");
      }
    }
  }

  @Test
  public void testThreadOrderCreation() throws EasyPostException, InterruptedException {

    // create a default set of shipment and order params to feed to the threads
    Map<String, Object> shipment_1 = orderShipment();
    List<Map<String, Object>> shipments = new ArrayList<Map<String, Object>>();
    shipments.add(shipment_1);
    Map<String, Object> orderParams = new HashMap<String, Object>();
    orderParams.put("shipments", shipments);
    orderParams.put("from_address", defaultFromAddress);
    orderParams.put("to_address", defaultToAddress);

    // divide up the orders among the threads
    List<Map<String, Object>> orderBatch1 = new ArrayList<Map<String, Object>>();
    List<Map<String, Object>> orderBatch2 = new ArrayList<Map<String, Object>>();
    orderBatch1.add(orderParams);
    orderBatch1.add(orderParams);
    orderBatch2.add(orderParams);
    orderBatch2.add(orderParams);

    System.out.println("Starting CreateOrders threads.");
    List<Thread> threads = new ArrayList<Thread>();
    threads.add(new Thread(new CreateOrders(orderBatch1)));
    threads.add(new Thread(new CreateOrders(orderBatch2)));

    for (Thread thread : threads) {
      thread.start();
    }
    for (Thread thread : threads) {
      thread.join();
    }
    System.out.println("Done CreateOrders threads!");

    // for more information on threads including adding timeouts and interrupts see:
    // http://docs.oracle.com/javase/tutorial/essential/concurrency/index.html

  }
}