Add some synchronization to the JsonStreamParser to ensure that the "next" method behaves according to the API.

gson/src/main/java/com/google/gson/JsonStreamParser.java

@@ -23,7 +23,23 @@ import java.util.NoSuchElementException;
 
 /**
  * A streaming parser that allows reading of multiple {@link JsonElement}s from the specified reader
- * asynchronously. This class is not thread-safe.
+ * asynchronously.
+ * 
+ * <p>This class is thread-compatible. For some more literature on these definitions, refer to
+ * Effective Java.
+ *
+ * <p>To properly use this class across multiple thread, you will need to add some external
+ * synchronization to your classes/thread to get this to work properly.  For example:
+ * 
+ * <pre>
+ * JsonStreamParser parser = new JsonStreamParser("blah blah blah");
+ * JsonElement element;
+ * synchronized (someCommonObject) {
+ *   if (parser.hasNext()) {
+ *     element = parser.next();
+ *   }
+ * }
+ * </pre>
  *
  * @author Inderjeet Singh
  * @author Joel Leitch
@@ -32,6 +48,7 @@ import java.util.NoSuchElementException;
 public final class JsonStreamParser implements Iterator<JsonElement> {
 
   private final JsonParserJavacc parser;
+  private final Object lock;
   private JsonElement nextElement;
 
   /**
@@ -48,6 +65,7 @@ public final class JsonStreamParser implements Iterator<JsonElement> {
    */
   public JsonStreamParser(Reader reader) {
     parser = new JsonParserJavacc(reader);
+    lock = new Object();
     nextElement = null;
   }
   
@@ -59,11 +77,14 @@ public final class JsonStreamParser implements Iterator<JsonElement> {
    * @since 1.4
    */
   public JsonElement next() throws JsonParseException {
+    synchronized (lock) {
       if (nextElement != null) {
         JsonElement returnValue = nextElement;
         nextElement = null;
         return returnValue;
       }
+    }
+
     try {
       return parser.parse();
     } catch (TokenMgrError e) {
@@ -84,6 +105,7 @@ public final class JsonStreamParser implements Iterator<JsonElement> {
   }
 
   public boolean hasNext() {
+    synchronized (lock) {
       try {
         nextElement = next();
         return true;
@@ -92,6 +114,7 @@ public final class JsonStreamParser implements Iterator<JsonElement> {
         return false;
       }
     }
+  }
 
   public void remove() {
     throw new UnsupportedOperationException();