- html - 出于某种原因,IE8 对我的 Sass 文件中继承的 html5 CSS 不友好?
- JMeter 在响应断言中使用 span 标签的问题
- html - 在 :hover and :active? 上具有不同效果的 CSS 动画
- html - 相对于居中的 html 内容固定的 CSS 重复背景?
我的要求如下
因此,缓存写入操作可以由多个线程同时执行,但是刷新缓存到数据库应该定期发生 1 个线程(每 1 秒)。下面是我的实现
static Map<String, Long> cacheTimer = new ConcurrentHashMap<String, Long>();
static Map<String, Date> cache = new ConcurrentHashMap<String, Date>();
private Map<String, Object> bucketTimeUpdatedLockMap = new ConcurrentHashMap<String, Object>();
public void updateCacheLastDequeuedTime(String queueName,
int bucketId, Date lastDequeued, boolean force) {
//Below is non-expensive cache write opration
String queueBucketId = queueName + bucketId;
// If the cache structures don't exist yet, set them up.
if (!cacheTimer.containsKey(queueBucketId)
|| !cache.containsKey(queueBucketId)) {
log.debug(
"Setting up bucketmapPendingLastDequeuedWrites cache for queue {}",
queueName);
cacheTimer.putIfAbsent(queueBucketId,0L);
cache.putIfAbsent(queueBucketId, new Date());
}
if (!cache.containsKey(queueBucketId)) {
cache.put(queueBucketId,lastDequeued);
} else {
Date tempDate = cache.get(queueBucketId);
if (tempDate != null && tempDate.equals(lastDequeued)) {
cache.put(queueBucketId,
QueueServiceUtils.incrementDateByMilliSeconds(
lastDequeued, 1));
} else {
cache.put(queueBucketId,lastDequeued);
}
}
//Below is cache expensive flush operation
if (force
|| System.currentTimeMillis()
- cacheTimer
.get(queueBucketId) > 1000)) {
flushCache(queueName, bucketId);
}
}
private void flushCache(String queueName, int bucketId) {
String queuebucketId = queueName + bucketId;
Object bucketTimeUpdatedLock = getBucketTimeUpdatedLock(queuebucketId); //taking a lock over an object
synchronized(bucketTimeUpdatedLock){
//rechecking
if (cacheTimer.containsKey(queuebucketId) && System.currentTimeMillis()
- cacheTimer.get(queuebucketId) > 1000)){
// why setting timer here? To keep a track when the last time this cache got flushed
cacheTimer.put(queuebucketId,
System.currentTimeMillis());
if (cache.containsKey(queuebucketId)
&& cache.get(queuebucketId) != null) {
Date lastDequeuedTime = cache.get(queuebucketId);
//below is an expensive operation.
queueServiceMetaDao.updateLastDequed(lastDequeuedTime, queueName, bucketId);
cache.remove(queuebucketId); //reset cache
}
}
}
}
//THis method will help in lock splitting instead of taking lock on queue take lock on bucket of queue (1 queue has 100 buckets)
private Object getBucketTimeUpdatedLock(String queueName) {
Object readBucketAssignLock = bucketTimeUpdatedLockMap.get(queueName);
if (readBucketAssignLock == null) {
log.debug(
"getting bucketTimeUpdatedLock for newly created queue {}",
queueName);
Object lock = new Object();
readBucketAssignLock = bucketTimeUpdatedLockMap.putIfAbsent(
queueName, lock);
if (readBucketAssignLock == null)
readBucketAssignLock = lock;
}
return readBucketAssignLock;
}
以下是我的疑问:
1.我的上述实现没有完全满足第三个要求“确保刷新时不应将数据写入缓存”。
如何将我的数据库操作安全地带到同步块(synchronized block)之外。
我应该使用 ReentrantReadWriteLock 而不是同步块(synchronized block)吗?因为我将进行并行写入缓存操作(每秒 15-50 个,因此分配读锁?),但是只有 1 个刷新操作(分配写锁?)
最佳答案
我强烈考虑使用 Guava Cache
具有基于时间的到期时间,并且如果确实需要防止条目在刷新到数据库时写入缓存,请使用同步删除监听器。
考虑一下同步监听器是否绝对必要,因为它可能会显着降低缓存的性能。
来自文档:
Warning: removal listener operations are executed synchronously by default, and since cache maintenance is normally performed during normal cache operations, expensive removal listeners can slow down normal cache function! If you have an expensive removal listener, use RemovalListeners.asynchronous(RemovalListener, Executor) to decorate a RemovalListener to operate asynchronously.
更多详情,请参阅 https://github.com/google/guava/wiki/CachesExplained .
关于java - 如何安全地将昂贵的数据库操作带到同步块(synchronized block)之外以避免争用,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/38062763/
我们已经有一个使用 AnyEvent 的库。它在内部使用 AnyEvent,并最终返回一个值(同步 - 不使用回调)。有什么方法可以将这个库与 Mojolicious 一起使用吗? 它的作用如下: #
我想从 XSD 文件生成带有 JAXB 的 Java 类。 问题是,我总是得到一些像这样的类(删除了命名空间): public static class Action { @X
我有一个关于 html 输入标签或 primefaces p:input 的问题。为什么光标总是自动跳转到输入字段。我的页面高度很高,因此您需要向下滚动。输入字段位于页面末尾,光标自动跳转(加载)到页
我今天在考虑面向对象设计,我想知道是否应该避免 if 语句。我的想法是,在任何需要 if 语句的情况下,您都可以简单地创建两个实现相同方法的对象。这两个方法实现只是原始 if 语句的两个可能的分支。
String graphNameUsed = graphName.getName(); if (graphType.equals("All") || graphType.equals(
我有一张友谊 table CREATE TABLE IF NOT EXISTS `friendList` ( `id` int(10) NOT NULL, `id_friend` int(10
上下文 Debian 64。Core 2 二人组。 摆弄循环。我使用了同一循环的不同变体,但我希望尽可能避免条件分支。 但是,即使我认为它也很难被击败。 我考虑过 SSE 或位移位,但它仍然需要跳转(
我最近在 Java 中创建了一个方法来获取字符串的排列,但是当字符串太长时它会抛出这个错误:java.lang.OutOfMemoryError: Java heap space我确信该方法是有效的,
我正在使用 (C++) 库,其中需要使用流初始化对象。库提供的示例代码使用此代码: // Declare the input stream HfstInputStream *in = NULL; tr
我有一个 SQL 查询,我在 WHERE 子句中使用子查询。然后我需要再次使用相同的子查询将其与不同的列进行比较。 我假设没有办法在子查询之外访问“emp_education_list li”? 我猜
我了解到在 GUI 线程上不允许进行网络操作。对我来说还可以。但是为什么在 Dialog 按钮点击回调上使用这段代码仍然会产生 NetworkOnMainThreadException ? new T
有没有办法避免在函数重定向中使用 if 和硬编码字符串,想法是接收一个字符串并调用适当的函数,可能使用模板/元编程.. #include #include void account() {
我正在尝试避免客户端出现 TIME_WAIT。我连接然后设置 O_NONBLOCK 和 SO_REUSEADDR。我调用 read 直到它返回 0。当 read 返回 0 时,errno 也为 0。我
我正在开发 C++ Qt 应用程序。为了在应用程序或其连接的设备出现故障时帮助用户,程序导出所有内部设置并将它们存储在一个普通文件(目前为 csv)中。然后将此文件发送到公司(例如通过邮件)。 为避免
我有一组具有公共(public)父类(super class)的 POJO。这些存储在 superclass 类型的二维数组中。现在,我想从数组中获取一个对象并使用子类 的方法。这意味着我必须将它们转
在我的代码中,当 List 为 null 时,我通常使用这种方法来避免 for 语句中的 NullPointerException: if (myList != null && myList.size
我正在尝试避免客户端出现 TIME_WAIT。我连接然后设置 O_NONBLOCK 和 SO_REUSEADDR。我调用 read 直到它返回 0。当 read 返回 0 时,errno 也为 0。我
在不支持异常的语言和/或库中,许多/几乎所有函数都会返回一个值,指示其操作成功或失败 - 最著名的例子可能是 UN*X 系统调用,例如 open( ) 或 chdir(),或一些 libc 函数。 无
我尝试按值提取行。 col1 df$col1[col1 == "A"] [1] "A" NA 当然我只想要“A”。如何避免 R 选择 NA 值?顺便说一句,我认为这种行为非常危险,因为很多人都会陷入
我想将两个向量合并到一个数据集中,并将其与函数 mutate 集成为 5 个新列到现有数据集中。这是我的示例代码: vector1% rowwise()%>% mutate(vector2|>
我是一名优秀的程序员,十分优秀!