1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
|
// Copyright 2015 The Chromium Authors. All rights reserved.
// Use of this source code is governed by a BSD-style license that can be
// found in the LICENSE file.
#include "core/html/parser/TokenizedChunkQueue.h"
#include "platform/RuntimeEnabledFeatures.h"
#include <algorithm>
#include <memory>
namespace blink {
namespace {
// TODO(csharrison): Remove this temporary class when the ParseHTMLOnMainThread
// experiment ends.
class MaybeLocker {
public:
MaybeLocker(Mutex* mutex) : m_mutex(mutex) {
if (m_mutex)
m_mutex->lock();
}
~MaybeLocker() {
if (m_mutex)
m_mutex->unlock();
}
private:
Mutex* m_mutex;
};
} // namespace
TokenizedChunkQueue::TokenizedChunkQueue()
: m_mutex(RuntimeEnabledFeatures::parseHTMLOnMainThreadEnabled()
? nullptr
: new Mutex) {}
TokenizedChunkQueue::~TokenizedChunkQueue() {}
bool TokenizedChunkQueue::enqueue(
std::unique_ptr<HTMLDocumentParser::TokenizedChunk> chunk) {
MaybeLocker locker(m_mutex.get());
m_pendingTokenCount += chunk->tokens->size();
m_peakPendingTokenCount =
std::max(m_peakPendingTokenCount, m_pendingTokenCount);
bool wasEmpty = m_pendingChunks.isEmpty();
m_pendingChunks.push_back(std::move(chunk));
m_peakPendingChunkCount =
std::max(m_peakPendingChunkCount, m_pendingChunks.size());
return wasEmpty;
}
void TokenizedChunkQueue::clear() {
MaybeLocker locker(m_mutex.get());
m_pendingTokenCount = 0;
m_pendingChunks.clear();
}
void TokenizedChunkQueue::takeAll(
Vector<std::unique_ptr<HTMLDocumentParser::TokenizedChunk>>& vector) {
MaybeLocker locker(m_mutex.get());
DCHECK(vector.isEmpty());
m_pendingChunks.swap(vector);
}
size_t TokenizedChunkQueue::peakPendingChunkCount() {
MaybeLocker locker(m_mutex.get());
return m_peakPendingChunkCount;
}
size_t TokenizedChunkQueue::peakPendingTokenCount() {
MaybeLocker locker(m_mutex.get());
return m_peakPendingTokenCount;
}
} // namespace blink
|
