#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/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);	×
18
19	public ObjectPool(int size, ObjectFactory<T> factory) {	×
20	this.size = size;	×
21	this.factory = factory;	×
22	queue = new ArrayBlockingQueue<>(size);	×
23	for (int i = 0; i < size; i++) {	×
24	queue.add(factory.create());	×
25	}
26	logger.debug("Init the object pool with size {}", size);	×
27	}	×
28
29	public T borrowObject() {
30	T t = queue.poll();	×
31	if(t == null) {	×
32	logger.debug("The pool is not enough, create a new object");	×
33	return factory.create();	×
34	}
35	return t;	×
36	}
37
38	public void returnObject(T obj) {
39	if (obj == null) {	×
40	return;	×
41	}
42	factory.reset(obj);	×
43	queue.offer(obj);	×
44	}	×
45
46	public interface ObjectFactory<T> {
47	T create();
48	void reset(T obj);
49	}
50	}

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