#418

Committed 30 Aug 2024 10:16AM UTC coverage: 88.839% (+0.01%) from 88.825%

Build # #418

Build Type

push

Committed by

Commit Message

remove unused map in EmbededCache (#921)

Run Details

4760 of 5358 relevant lines covered (88.84%)

0.89 hits per line

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

84.21

/jetcache-core/src/main/java/com/alicp/jetcache/support/ObjectPool.java

package com.alicp.jetcache.support;

import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

import java.util.concurrent.ArrayBlockingQueue;

/**
 * @Description
 * @author: zhangtong
 * @create: 2023/10/6 3:27 PM
 */
public class ObjectPool<T> {
        private final ArrayBlockingQueue<T> queue;
        private final int size;
        private final ObjectFactory<T> factory;
        private static final Logger logger = LoggerFactory.getLogger(ObjectPool.class);

        public ObjectPool(int size, ObjectFactory<T> factory) {
            this.size = size;
            this.factory = factory;
            queue = new ArrayBlockingQueue<>(size);
            for (int i = 0; i < size; i++) {
                queue.add(factory.create());
            }
            logger.debug("Init the object pool with size {}", size);
        }

        public T borrowObject() {
            T t = queue.poll();
            if(t == null) {
                logger.debug("The pool is not enough, create a new object");
                return factory.create();
            }
            return t;
        }

        public void returnObject(T obj) {
            if (obj == null) {
                return;
            }
            factory.reset(obj);
            queue.offer(obj);
        }

        public interface ObjectFactory<T> {
            T create();
            void reset(T obj);
        }
}

1	package com.alicp.jetcache.support;
2
3	import org.slf4j.Logger;
4	import org.slf4j.LoggerFactory;
5
6	import java.util.concurrent.ArrayBlockingQueue;
7
8	/**
9	* @Description
10	* @author: zhangtong
11	* @create: 2023/10/6 3:27 PM
12	*/
13	public class ObjectPool<T> {
14	private final ArrayBlockingQueue<T> queue;
15	private final int size;
16	private final ObjectFactory<T> factory;
17	private static final Logger logger = LoggerFactory.getLogger(ObjectPool.class);	1✔
18
19	public ObjectPool(int size, ObjectFactory<T> factory) {	1✔
20	this.size = size;	1✔
21	this.factory = factory;	1✔
22	queue = new ArrayBlockingQueue<>(size);	1✔
23	for (int i = 0; i < size; i++) {	1✔
24	queue.add(factory.create());	1✔
25	}
26	logger.debug("Init the object pool with size {}", size);	1✔
27	}	1✔
28
29	public T borrowObject() {
30	T t = queue.poll();	1✔
31	if(t == null) {	1✔
32	logger.debug("The pool is not enough, create a new object");	×
33	return factory.create();	×
34	}
35	return t;	1✔
36	}
37
38	public void returnObject(T obj) {
39	if (obj == null) {	1✔
40	return;	×
41	}
42	factory.reset(obj);	1✔
43	queue.offer(obj);	1✔
44	}	1✔
45
46	public interface ObjectFactory<T> {
47	T create();
48	void reset(T obj);
49	}
50	}

alibaba / jetcache / #418

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