##// END OF EJS Templates
implab » ImplabNet
RSS
JSONWriter improvements
cin -
r150:3258399cba83 v2
parent child
Show More
Show file before | Show file after | Hide comments
@@ -1,280 +1,319
1 1 using System;
2 2 using System.Collections.Generic;
3 3 using System.IO;
4 4 using System.Globalization;
5 using System.Diagnostics;
5 6
6 7 namespace Implab.JSON {
7 8 public class JSONWriter {
8 9 struct Context {
9 10 public bool needComma;
10 11 public JSONElementContext element;
11 12 }
12 13 Stack<Context> m_contextStack = new Stack<Context>();
13 14 Context m_context;
14 15
16 const int BUFFER_SIZE = 64;
17
15 18 TextWriter m_writer;
16 19 readonly bool m_indent = true;
17 20 readonly int m_indentSize = 4;
21 readonly char[] m_buffer = new char[BUFFER_SIZE];
22 int m_bufferPos;
18 23
24 static readonly char [] _hex = { '0', '1', '2', '3', '4', '5', '6', '7', '8', '9', 'a', 'b', 'c', 'd', 'e', 'f' };
19 25 static readonly char [] _escapeBKS,
20 26 _escapeFWD,
21 27 _escapeCR,
22 28 _escapeNL,
23 29 _escapeTAB,
24 30 _escapeBSLASH,
25 31 _escapeQ;
26 32
27 33 static JSONWriter() {
28 34 _escapeBKS = "\\b".ToCharArray();
29 35 _escapeFWD = "\\f".ToCharArray();
30 36 _escapeCR = "\\r".ToCharArray();
31 37 _escapeNL = "\\n".ToCharArray();
32 38 _escapeTAB = "\\t".ToCharArray();
33 39 _escapeBSLASH = "\\\\".ToCharArray();
34 40 _escapeQ = "\\\"".ToCharArray();
35 41 }
36 42
37 43 public JSONWriter(TextWriter writer) {
38 44 Safe.ArgumentNotNull(writer, "writer");
39 45 m_writer = writer;
40 46 }
41 47
42 48 public JSONWriter(TextWriter writer, bool indent) {
43 49 Safe.ArgumentNotNull(writer, "writer");
44 50
45 51 m_writer = writer;
46 52 m_indent = indent;
47 53 }
48 54
49 55 void WriteIndent() {
50 56 if (m_indent) {
51 57 var indent = new char[m_contextStack.Count * m_indentSize + 1];
52 58 indent[0] = '\n';
53 59 for (int i = 1; i < indent.Length; i++)
54 60 indent[i] = ' ';
55 61 m_writer.Write(new String(indent));
56 62 } else {
57 63 m_writer.Write(' ');
58 64 }
59 65 }
60 66
61 67 void WriteMemberName(string name) {
62 68 Safe.ArgumentNotEmpty(name, "name");
63 69 if (m_context.element != JSONElementContext.Object)
64 70 OperationNotApplicable("WriteMember");
65 71 if (m_context.needComma)
66 72 m_writer.Write(",");
67 73
68 74 WriteIndent();
69 75 m_context.needComma = true;
70 76 Write(name);
71 77 m_writer.Write(" : ");
72 78 }
73 79
74 80 public void WriteValue(string name, string value) {
75 81 WriteMemberName(name);
76 82 Write(value);
77 83 }
78 84
79 85 public void WriteValue(string name, bool value) {
80 86 WriteMemberName(name);
81 87 Write(value);
82 88 }
83 89
84 90 public void WriteValue(string name, double value) {
85 91 WriteMemberName(name);
86 92 Write(value);
87 93 }
88 94
89 95 public void WriteValue(string value) {
90 96 if (m_context.element == JSONElementContext.Array) {
91 97
92 98 if (m_context.needComma)
93 99 m_writer.Write(",");
94 100 WriteIndent();
95 101 m_context.needComma = true;
96 102
97 103 Write(value);
98 104 } else if (m_context.element == JSONElementContext.None) {
99 105 Write(value);
100 106 m_context.element = JSONElementContext.Closed;
101 107 } else {
102 108 OperationNotApplicable("WriteValue");
103 109 }
104 110 }
105 111
106 112 public void WriteValue(bool value) {
107 113 if (m_context.element == JSONElementContext.Array) {
108 114
109 115 if (m_context.needComma)
110 116 m_writer.Write(",");
111 117 WriteIndent();
112 118 m_context.needComma = true;
113 119
114 120 Write(value);
115 121 } else if (m_context.element == JSONElementContext.None) {
116 122 Write(value);
117 123 m_context.element = JSONElementContext.Closed;
118 124 } else {
119 125 OperationNotApplicable("WriteValue");
120 126 }
121 127 }
122 128
123 129 public void WriteValue(double value) {
124 130 if (m_context.element == JSONElementContext.Array) {
125 131
126 132 if (m_context.needComma)
127 133 m_writer.Write(",");
128 134 WriteIndent();
129 135 m_context.needComma = true;
130 136
131 137 Write(value);
132 138 } else if (m_context.element == JSONElementContext.None) {
133 139 Write(value);
134 140 m_context.element = JSONElementContext.Closed;
135 141 } else {
136 142 OperationNotApplicable("WriteValue");
137 143 }
138 144 }
139 145
140 146 public void BeginObject() {
141 147 if (m_context.element != JSONElementContext.None && m_context.element != JSONElementContext.Array)
142 148 OperationNotApplicable("BeginObject");
143 149 if (m_context.needComma)
144 150 m_writer.Write(",");
145 151
146 152 WriteIndent();
147 153
148 154 m_context.needComma = true;
149 155
150 156 m_contextStack.Push(m_context);
151 157
152 158 m_context = new Context { element = JSONElementContext.Object, needComma = false };
153 159 m_writer.Write("{");
154 160 }
155 161
156 162 public void BeginObject(string name) {
157 163 WriteMemberName(name);
158 164
159 165 m_contextStack.Push(m_context);
160 166
161 167 m_context = new Context { element = JSONElementContext.Object, needComma = false };
162 168 m_writer.Write("{");
163 169 }
164 170
165 171 public void EndObject() {
166 172 if (m_context.element != JSONElementContext.Object)
167 173 OperationNotApplicable("EndObject");
168 174
169 175 m_context = m_contextStack.Pop();
170 176 if (m_contextStack.Count == 0)
171 177 m_context.element = JSONElementContext.Closed;
172 178 WriteIndent();
173 179 m_writer.Write("}");
174 180 }
175 181
176 182 public void BeginArray() {
177 183 if (m_context.element != JSONElementContext.None && m_context.element != JSONElementContext.Array)
178 184 throw new InvalidOperationException();
179 185 if (m_context.needComma) {
180 186 m_writer.Write(",");
181 187
182 188 }
183 189 m_context.needComma = true;
184 190
185 191 WriteIndent();
186 192 m_contextStack.Push(m_context);
187 193 m_context = new Context { element = JSONElementContext.Array, needComma = false };
188 194 m_writer.Write("[");
189 195 }
190 196
191 197 public void BeginArray(string name) {
192 198 WriteMemberName(name);
193 199
194 200 m_contextStack.Push(m_context);
195 201
196 202 m_context = new Context { element = JSONElementContext.Array, needComma = false };
197 203 m_writer.Write("[");
198 204 }
199 205
200 206 public void EndArray() {
201 207 if (m_context.element != JSONElementContext.Array)
202 208 OperationNotApplicable("EndArray");
203 209
204 210 m_context = m_contextStack.Pop();
205 211 if (m_contextStack.Count == 0)
206 212 m_context.element = JSONElementContext.Closed;
207 213 WriteIndent();
208 214 m_writer.Write("]");
209 215 }
210 216
211 217 void Write(bool value) {
212 218 m_writer.Write(value ? "true" : "false");
213 219 }
214
220
221 void FlushBuffer() {
222 if (m_bufferPos > 0) {
223 m_writer.Write(m_buffer, 0, m_bufferPos);
224 m_bufferPos = 0;
225 }
226 }
215 227
216 228 void Write(string value) {
217 229 if (value == null) {
218 230 m_writer.Write("null");
219 231 return;
220 232 }
221 233
234 Debug.Assert(m_bufferPos == 0);
235
222 236 var chars = value.ToCharArray();
223 m_writer.Write('"');
224
237 m_buffer[m_bufferPos++] = '"';
238
225 239 // Analysis disable once ForCanBeConvertedToForeach
226 240 for (int i = 0; i < chars.Length; i++) {
227 241 var ch = chars[i];
228 242
243 char[] escapeSeq;
244
229 245 switch (ch) {
230 246 case '\b':
231 m_writer.Write(_escapeBKS);
247 escapeSeq = _escapeBKS;
232 248 break;
233 249 case '\f':
234 m_writer.Write(_escapeFWD);
250 escapeSeq = _escapeFWD;
235 251 break;
236 252 case '\r':
237 m_writer.Write(_escapeCR);
253 escapeSeq = _escapeCR;
238 254 break;
239 255 case '\n':
240 m_writer.Write(_escapeNL);
256 escapeSeq = _escapeNL;
241 257 break;
242 258 case '\t':
243 m_writer.Write(_escapeTAB);
259 escapeSeq = _escapeTAB;
244 260 break;
245 261 case '\\':
246 m_writer.Write(_escapeBSLASH);
262 escapeSeq = _escapeBSLASH;
247 263 break;
248 264 case '"':
249 m_writer.Write(_escapeQ);
265 escapeSeq = _escapeQ;
250 266 break;
251 267 default:
252 268 if (ch < 0x20) {
253 m_writer.Write("\\u00{0:x2}",(int)ch);
269 if (m_bufferPos + 6 > BUFFER_SIZE)
270 FlushBuffer();
271
272 m_buffer[m_bufferPos++] = '\\';
273 m_buffer[m_bufferPos++] = 'u';
274 m_buffer[m_bufferPos++] = '0';
275 m_buffer[m_bufferPos++] = '0';
276 m_buffer[m_bufferPos++] = _hex[ch >> 4 & 0xf];
277 m_buffer[m_bufferPos++] = _hex[ch & 0xf];
278
254 279 } else {
255 m_writer.Write(ch);
280 if (m_bufferPos >= BUFFER_SIZE)
281 FlushBuffer();
282 m_buffer[m_bufferPos++] = ch;
256 283 }
257 break;
284 continue;
258 285 }
286
287 if (m_bufferPos + escapeSeq.Length > BUFFER_SIZE)
288 FlushBuffer();
289
290 Array.Copy(escapeSeq, 0, m_buffer, m_bufferPos, escapeSeq.Length);
291 m_bufferPos += escapeSeq.Length;
292
259 293 }
260 294
261 m_writer.Write('"');
295 if (m_bufferPos >= BUFFER_SIZE)
296 FlushBuffer();
297
298 m_buffer[m_bufferPos++] = '"';
299
300 FlushBuffer();
262 301 }
263 302
264 303 void Write(double value) {
265 304 if (double.IsNaN(value))
266 305 Write("NaN");
267 306 else if (double.IsNegativeInfinity(value))
268 307 Write("-Infinity");
269 308 else if (double.IsPositiveInfinity(value))
270 309 Write("Infinity");
271 310 else
272 311 m_writer.Write(value.ToString(CultureInfo.InvariantCulture));
273 312 }
274 313
275 314 void OperationNotApplicable(string opName) {
276 315 throw new InvalidOperationException(String.Format("The operation '{0}' isn't applicable in the context of '{1}'", opName, m_context.element ));
277 316 }
278 317
279 318 }
280 319 }
Show file before | Show file after | Hide comments
@@ -1,40 +1,44
1 1 using System;
2 2 using Implab.Diagnostics;
3 3 using Implab.Parallels;
4 4 using Implab;
5 5 using System.Collections.Generic;
6 6 using System.Collections.Concurrent;
7 7 using System.Threading;
8 using Implab.JSON;
9 using System.IO;
8 10
9 11 namespace MonoPlay {
10 12 class MainClass {
11 13
12 14
13 15 public static void Main(string[] args) {
14 16 if (args == null)
15 17 throw new ArgumentNullException("args");
16 18
17 19 var t1 = Environment.TickCount;
18 20
19 for (int i = 0; i < 10000000; i++) {
20
21 var p = new Promise<int>();
22 p.On(HandleResult);
23 p.Resolve(i);
21 for(int i =0; i < 1000000; i++)
22 using (var tw = new StringWriter()) {
23 var jw = new JSONWriter(tw);
24
25 jw.WriteValue("\r\nhere\tvalue\u0002\u0003");
26
27 //Console.WriteLine(tw);
24 28 }
25 29
30
31
26 32 var t2 = Environment.TickCount;
27 33 Console.WriteLine("done: {0} ms, {1:.00} Mb, {2} GC", t2 - t1, GC.GetTotalMemory(false) / (1024*1024), GC.CollectionCount(0) );
28 34
29 35 }
30 36
31 static void HandleAction ()
32 {
33
37 static void DoTest() {
38
39
40
34 41 }
35 42
36 static void HandleResult(int x) {
37
38 }
39 43 }
40 44 }
General Comments 0
You need to be logged in to leave comments. Login now