#405

Committed 16 Apr 2024 05:58AM UTC coverage: 0.0% (-88.9%) from 88.866%

Build # #405

Build Type

push

Committed by

Commit Message

add encoding to fix coverage report

Run Details

0 of 5353 relevant lines covered (0.0%)

0.0 hits per line

Source File
Press 'n' to go to next uncovered line, 'b' for previous

0.0

/jetcache-core/src/main/java/com/alicp/jetcache/embedded/Cleaner.java

package com.alicp.jetcache.embedded;

import com.alicp.jetcache.support.JetCacheExecutor;

import java.lang.ref.WeakReference;
import java.util.Iterator;
import java.util.LinkedList;
import java.util.concurrent.ScheduledExecutorService;
import java.util.concurrent.TimeUnit;
import java.util.concurrent.locks.ReentrantLock;

/**
 * Created on 2017/2/28.
 *
 * @author huangli
 */
class Cleaner {

    static LinkedList<WeakReference<LinkedHashMapCache>> linkedHashMapCaches = new LinkedList<>();
    private static final ReentrantLock reentrantLock = new  ReentrantLock();

    static {
        ScheduledExecutorService executorService = JetCacheExecutor.defaultExecutor();
        executorService.scheduleWithFixedDelay(() -> run(), 60, 60, TimeUnit.SECONDS);
    }

    static void add(LinkedHashMapCache cache) {
        reentrantLock.lock();
        try{
            linkedHashMapCaches.add(new WeakReference<>(cache));
        }finally {
            reentrantLock.unlock();
        }
    }

    static void run() {
        reentrantLock.lock();
        try{
            Iterator<WeakReference<LinkedHashMapCache>> it = linkedHashMapCaches.iterator();
            while (it.hasNext()) {
                WeakReference<LinkedHashMapCache> ref = it.next();
                LinkedHashMapCache c = ref.get();
                if (c == null) {
                    it.remove();
                } else {
                    c.cleanExpiredEntry();
                }
            }
        }finally {
            reentrantLock.unlock();
        }
    }

}

1	package com.alicp.jetcache.embedded;
2
3	import com.alicp.jetcache.support.JetCacheExecutor;
4
5	import java.lang.ref.WeakReference;
6	import java.util.Iterator;
7	import java.util.LinkedList;
8	import java.util.concurrent.ScheduledExecutorService;
9	import java.util.concurrent.TimeUnit;
10	import java.util.concurrent.locks.ReentrantLock;
11
12	/**
13	* Created on 2017/2/28.
14	*
15	* @author huangli
16	*/
17	class Cleaner {	×
18
19	static LinkedList<WeakReference<LinkedHashMapCache>> linkedHashMapCaches = new LinkedList<>();	×
20	private static final ReentrantLock reentrantLock = new ReentrantLock();	×
21
22	static {
23	ScheduledExecutorService executorService = JetCacheExecutor.defaultExecutor();	×
24	executorService.scheduleWithFixedDelay(() -> run(), 60, 60, TimeUnit.SECONDS);	×
25	}	×
26
27	static void add(LinkedHashMapCache cache) {
28	reentrantLock.lock();	×
29	try{
30	linkedHashMapCaches.add(new WeakReference<>(cache));	×
31	}finally {
32	reentrantLock.unlock();	×
33	}
34	}	×
35
36	static void run() {
37	reentrantLock.lock();	×
38	try{
39	Iterator<WeakReference<LinkedHashMapCache>> it = linkedHashMapCaches.iterator();	×
40	while (it.hasNext()) {	×
41	WeakReference<LinkedHashMapCache> ref = it.next();	×
42	LinkedHashMapCache c = ref.get();	×
43	if (c == null) {	×
44	it.remove();	×
45	} else {
46	c.cleanExpiredEntry();	×
47	}
48	}	×
49	}finally {
50	reentrantLock.unlock();	×
51	}
52	}	×
53
54	}

alibaba / jetcache / #405

Source File Press 'n' to go to next uncovered line, 'b' for previous

Source File
Press 'n' to go to next uncovered line, 'b' for previous