LineBreakIteratorPoolICU.h [plain text]
#ifndef LineBreakIteratorPoolICU_h
#define LineBreakIteratorPoolICU_h
#include "TextBreakIterator.h"
#include "TextBreakIteratorInternalICU.h"
#include <unicode/ubrk.h>
#include <wtf/Assertions.h>
#include <wtf/HashMap.h>
#include <wtf/ThreadSpecific.h>
#include <wtf/text/AtomicString.h>
#include <wtf/text/CString.h>
#include <wtf/text/StringBuilder.h>
namespace WebCore {
class LineBreakIteratorPool {
WTF_MAKE_NONCOPYABLE(LineBreakIteratorPool);
public:
LineBreakIteratorPool() { }
static LineBreakIteratorPool& sharedPool()
{
static WTF::ThreadSpecific<LineBreakIteratorPool>* pool = new WTF::ThreadSpecific<LineBreakIteratorPool>;
return **pool;
}
static String makeLocaleWithBreakKeyword(const AtomicString& locale, LineBreakIteratorMode mode)
{
StringBuilder localeWithKeyword;
localeWithKeyword.append(locale);
localeWithKeyword.appendLiteral("@break=");
switch (mode) {
case LineBreakIteratorModeUAX14:
ASSERT_NOT_REACHED();
break;
case LineBreakIteratorModeUAX14Loose:
localeWithKeyword.appendLiteral("loose");
break;
case LineBreakIteratorModeUAX14Normal:
localeWithKeyword.appendLiteral("normal");
break;
case LineBreakIteratorModeUAX14Strict:
localeWithKeyword.appendLiteral("strict");
break;
}
return localeWithKeyword.toString();
}
TextBreakIterator* take(const AtomicString& locale, LineBreakIteratorMode mode, bool isCJK)
{
AtomicString localeWithOptionalBreakKeyword;
if (mode == LineBreakIteratorModeUAX14)
localeWithOptionalBreakKeyword = locale;
else
localeWithOptionalBreakKeyword = makeLocaleWithBreakKeyword(locale, mode);
TextBreakIterator* iterator = 0;
for (size_t i = 0; i < m_pool.size(); ++i) {
if (m_pool[i].first == localeWithOptionalBreakKeyword) {
iterator = m_pool[i].second;
m_pool.remove(i);
break;
}
}
if (!iterator) {
iterator = openLineBreakIterator(localeWithOptionalBreakKeyword, mode, isCJK);
if (!iterator)
return 0;
}
ASSERT(!m_vendedIterators.contains(iterator));
m_vendedIterators.set(iterator, localeWithOptionalBreakKeyword);
return iterator;
}
void put(TextBreakIterator* iterator)
{
ASSERT_ARG(iterator, m_vendedIterators.contains(iterator));
if (m_pool.size() == capacity) {
closeLineBreakIterator(m_pool[0].second);
m_pool.remove(0);
}
m_pool.append(Entry(m_vendedIterators.take(iterator), iterator));
}
private:
static const size_t capacity = 4;
typedef std::pair<AtomicString, TextBreakIterator*> Entry;
typedef Vector<Entry, capacity> Pool;
Pool m_pool;
HashMap<TextBreakIterator*, AtomicString> m_vendedIterators;
friend WTF::ThreadSpecific<LineBreakIteratorPool>::operator LineBreakIteratorPool*();
};
}
#endif