async def METHOD_NAME(create_actors_with_delay):
    worker_address, sub_pool_address1, sub_pool_address2 = create_actors_with_delay
    storage_handler1 = await mo.actor_ref(
        uid=StorageHandlerActor.gen_uid("numa-0"), address=sub_pool_address1
    )
    storage_handler2 = await mo.actor_ref(
        uid=StorageHandlerActor.gen_uid("numa-0"), address=sub_pool_address2
    )
    # total store size is 65536, single data size is around 40000
    # we put two data simultaneously
    data = np.random.randint(0, 10000, (5000,))
    session_id = "mock_session"
    key1 = "mock_key1"
    key2 = "mock_key2"
    put1 = asyncio.create_task(
        storage_handler1.put(session_id, key1, data, StorageLevel.MEMORY)
    )
    put2 = asyncio.create_task(
        storage_handler2.put(session_id, key2, data, StorageLevel.MEMORY)
    )
    await asyncio.gather(put1, put2)
    get_data = await storage_handler2.get(session_id, key1)
    np.testing.assert_array_equal(data, get_data)
    get_data = await storage_handler1.get(session_id, key2)
    np.testing.assert_array_equal(data, get_data)
    memory_object_list = await storage_handler1.list(StorageLevel.MEMORY)
    disk_object_list = await storage_handler1.list(StorageLevel.DISK)
    assert len(memory_object_list) == 1
    assert len(disk_object_list) == 1