【Python笔记-设计模式】对象池模式

news2024/11/14 15:37:13

一、说明

用于管理对象的生命周期，重用已经创建的对象，从而减少资源消耗和创建对象的开销

(一) 解决问题

主要解决频繁创建和销毁对象所带来的性能开销问题。如数据库连接、线程管理、网络连接等，对象的创建和销毁成本相对较高，如果频繁进行这些操作，会消耗大量的系统资源，并可能导致性能瓶颈。

(二) 使用场景

资源受限时，如果CPU性能不够强劲或内存比较紧张，垃圾收集和内存抖动可能会造成较大影响。在这种情况下，提高内存管理效率尤为重要，对象池模式可以帮助减少内存分配和再分配的成本，避免内存碎片。
创建高成本对象时，对于那些创建成本较高的对象，如数据库连接、线程或网络连接，对象池模式可以显著减少创建和销毁这些对象的开销。
频繁创建和销毁对象的场景，在需要频繁创建和销毁对象的场景中，如任务队列池、网络连接池等，对象池模式可以显著提高性能。

二、结构

对象池（ObjectPool）：这是对象池模式的核心组件，负责创建、初始化和管理对象池中的对象。对象池持有一组已经初始化并且可以使用的对象，提供对外借出和归还对象的方法。
抽象池化对象（IPooledObject）：这是一个抽象接口或基类，定义了池化对象应该具备的基本操作和行为。它通常包括对象的状态管理（如是否在使用中、是否需要销毁等）和对象池相关的操作（如借出、归还等）。
具体池化对象（ConcretePoolObject）：这是实现了抽象池化对象的具体类，封装了池化对象的实际状态和行为。具体池化对象在被借出时提供给客户端使用，并在使用完毕后归还给对象池。
客户端（Client）：这是使用对象池模式的代码部分，通过向对象池请求对象来使用，并在使用完毕后将对象归还给对象池。客户端不需要关心对象的创建和销毁过程，只需要从对象池中获取对象并使用即可。

三、伪代码

#!/usr/bin/env python
# -*- coding: UTF-8 -*-
__doc__ = """
对象池模式

例：创建一个对象池，验证是否可以重用对象
"""

import queue
import threading


class ObjectPool:
    """
    创建对象池，用于管理对象
    """

    def __init__(self, object_type, max_size=10):
        self._lock = threading.Lock()
        self._objects = queue.Queue(max_size)
        self._object_type = object_type
        self._max_size = max_size

    def acquire_object(self):
        """
        从对象池中获取一个对象
        """
        with self._lock:
            try:
                obj = self._objects.get(block=False)
            except queue.Empty:
                obj = self._object_type()
        return obj

    def release_object(self, obj):
        """
        将一个对象归还给对象池
        """
        with self._lock:
            try:
                self._objects.put(obj, block=False)
            except queue.Full:
                pass


class MyObject:
    def __init__(self):
        pass

    @staticmethod
    def do_something():
        print("Doing something...")


if __name__ == '__main__':
    """
    Doing something...
    4416796512
    Doing something...
    4416796512
    """
    # 创建对象池
    object_pool = ObjectPool(MyObject, max_size=2)

    obj1 = object_pool.acquire_object()
    obj1.do_something()
    print(id(obj1))
    object_pool.release_object(obj1)

    obj2 = object_pool.acquire_object()
    obj2.do_something()
    print(id(obj2))
    object_pool.release_object(obj2)