Skip to content

Commit

Permalink
perf(ssr): avoid unnecessary await ticks when unrolling sync buffers
Browse files Browse the repository at this point in the history
  • Loading branch information
yyx990803 committed Jun 26, 2020
1 parent 6bc0e0a commit 30584bc
Show file tree
Hide file tree
Showing 3 changed files with 54 additions and 10 deletions.
10 changes: 8 additions & 2 deletions packages/server-renderer/src/render.ts
Original file line number Diff line number Diff line change
Expand Up @@ -20,7 +20,8 @@ import {
isPromise,
isString,
isVoidTag,
ShapeFlags
ShapeFlags,
isArray
} from '@vue/shared'
import { ssrRenderAttrs } from './helpers/ssrRenderAttrs'
import { ssrCompile } from './helpers/ssrCompile'
Expand All @@ -35,7 +36,7 @@ const {
normalizeSuspenseChildren
} = ssrUtils

export type SSRBuffer = SSRBufferItem[]
export type SSRBuffer = SSRBufferItem[] & { hasAsync?: boolean }
export type SSRBufferItem = string | SSRBuffer | Promise<SSRBuffer>
export type PushFn = (item: SSRBufferItem) => void
export type Props = Record<string, unknown>
Expand Down Expand Up @@ -68,6 +69,11 @@ export function createBuffer() {
buffer.push(item)
}
appendable = isStringItem
if (isPromise(item) || (isArray(item) && item.hasAsync)) {
// promise, or child buffer with async, mark as async.
// this allows skipping unnecessary await ticks during unroll stage
buffer.hasAsync = true
}
}
}
}
Expand Down
26 changes: 22 additions & 4 deletions packages/server-renderer/src/renderToStream.ts
Original file line number Diff line number Diff line change
Expand Up @@ -16,15 +16,33 @@ async function unrollBuffer(
buffer: SSRBuffer,
stream: Readable
): Promise<void> {
if (buffer.hasAsync) {
for (let i = 0; i < buffer.length; i++) {
let item = buffer[i]
if (isPromise(item)) {
item = await item
}
if (isString(item)) {
stream.push(item)
} else {
await unrollBuffer(item, stream)
}
}
} else {
// sync buffer can be more efficiently unrolled without unnecessary await
// ticks
unrollBufferSync(buffer, stream)
}
}

function unrollBufferSync(buffer: SSRBuffer, stream: Readable) {
for (let i = 0; i < buffer.length; i++) {
let item = buffer[i]
if (isPromise(item)) {
item = await item
}
if (isString(item)) {
stream.push(item)
} else {
await unrollBuffer(item, stream)
// since this is a sync buffer, child buffers are never promises
unrollBufferSync(item as SSRBuffer, stream)
}
}
}
Expand Down
28 changes: 24 additions & 4 deletions packages/server-renderer/src/renderToString.ts
Original file line number Diff line number Diff line change
Expand Up @@ -12,16 +12,36 @@ import { SSRContext, renderComponentVNode, SSRBuffer } from './render'
const { isVNode } = ssrUtils

async function unrollBuffer(buffer: SSRBuffer): Promise<string> {
if (buffer.hasAsync) {
let ret = ''
for (let i = 0; i < buffer.length; i++) {
let item = buffer[i]
if (isPromise(item)) {
item = await item
}
if (isString(item)) {
ret += item
} else {
ret += await unrollBuffer(item)
}
}
return ret
} else {
// sync buffer can be more efficiently unrolled without unnecessary await
// ticks
return unrollBufferSync(buffer)
}
}

function unrollBufferSync(buffer: SSRBuffer): string {
let ret = ''
for (let i = 0; i < buffer.length; i++) {
let item = buffer[i]
if (isPromise(item)) {
item = await item
}
if (isString(item)) {
ret += item
} else {
ret += await unrollBuffer(item as SSRBuffer)
// since this is a sync buffer, child buffers are never promises
ret += unrollBufferSync(item as SSRBuffer)
}
}
return ret
Expand Down

0 comments on commit 30584bc

Please sign in to comment.