diff --git a/libvirt/tests/cfg/multivm_stress/multi_vms_with_stress.cfg b/libvirt/tests/cfg/multivm_stress/multi_vms_with_stress.cfg
new file mode 100644
index 0000000000..426d7fa86f
--- /dev/null
+++ b/libvirt/tests/cfg/multivm_stress/multi_vms_with_stress.cfg
@@ -0,0 +1,4 @@
+- multi_vms_with_stress:
+    type = multi_vms_with_stress
+    vm_names = test-vm1 test-vm2 test-vm3
+    stress_args = '--cpu 4 --io 4 --vm 2 --vm-bytes 128M &'
diff --git a/libvirt/tests/src/multivm_stress/multi_vms_with_stress.py b/libvirt/tests/src/multivm_stress/multi_vms_with_stress.py
new file mode 100644
index 0000000000..153c009e19
--- /dev/null
+++ b/libvirt/tests/src/multivm_stress/multi_vms_with_stress.py
@@ -0,0 +1,111 @@
+import logging as log
+
+from avocado.utils import cpu
+
+from virttest import utils_stress
+from virttest import error_context
+from virttest import utils_test
+from virttest import virt_vm
+from virttest import cpu as cpuutil
+from virttest.libvirt_xml import vm_xml
+from virttest.utils_misc import cmd_status_output
+
+LOG = log.getLogger('avocado.' + __name__)
+
+
+def run(test, params, env):
+    """
+    """
+    main_vm_name = params.get("main_vm")
+    main_vm = env.get_vm(main_vm_name)
+    stress_args = params.get("stress_args", "--cpu 4 --io 4 --vm 2 --vm-bytes 128M &")
+
+    main_vmxml = vm_xml.VMXML.new_from_inactive_dumpxml(main_vm_name)
+    main_vmxml_backup = main_vmxml.copy()
+
+    vm_names = params.get("vm_names").split()
+    vms = []
+
+
+
+# virt-install --connect qemu:///system -n avocado-vt-vm1 --hvm --accelerate -r 2048 --vcpus=2 
+# --os-variant rhel9.5 --import --noreboot --noautoconsole --serial pty --debug  
+# --disk path=/var/lib/avocado/data/avocado-vt/images/jeos-27-aarch64.qcow2,bus=virtio,format=qcow2,cache=none,driver.discard=unmap,driver.io=native 
+# --network network=default,model=virtio,driver.queues=2  --memballoon model=virtio --graphics vnc --boot uefi
+
+    for vm_name in vm_names:
+        disk_path = "path=/var/lib/avocado/data/avocado-vt/images/jeos-27-aarch64.qcow2,bus=virtio,format=qcow2,cache=none,driver.discard=unmap,driver.io=native"
+        cmd = ("virt-install --name %s"
+                " --disk %s"
+                " --connect qemu:///system"
+                " --hvm --accelerate"
+                " -r 2048"
+                " --os-variant rhel9.5"
+                " --import"
+                " --noreboot --noautoconsole --nographics"
+                " --serial pty"
+                " --network network=default,model=virtio,driver.queues=2"
+                " --memballoon model=virtio"
+                " --boot uefi"
+                " --check path_in_use=off"
+                " --debug" %
+                (vm_name, disk_path))
+
+        cmd_status_output(cmd, shell=True, timeout=600)
+        LOG.debug("Installation finished for %s", vm_name)
+        env.create_vm(vm_type='libvirt', target=None, name=vm_name, params=params, bindir=test.bindir)
+        vms.append(env.get_vm(vm_name))
+        LOG.debug("vms %s", vms)
+    
+    # env_vms = env.get_all_vms()
+    # LOG.debug("vms %s and %s", (vms, env_vms))
+
+    try:
+        # Get host online cpu number
+        host_online_cpus = cpu.online_count()
+        LOG.debug("Host online CPU number: %s", str(host_online_cpus))
+
+        # Prepare 3 vms and each vm has even vcpus number which is about 2/3 of # host_online_cpu 
+        for i, vm in enumerate(vms):
+            LOG.debug("~~~in for loop")
+            if vm.is_alive():
+                vm.destroy()
+            LOG.debug("~~~vm name %s", vm.name)
+            num_vms = int(len(vms))
+            vcpus_num = host_online_cpus * 2 // num_vms
+            LOG.debug("~~~num vms %s", num_vms)
+            LOG.debug("~~~vcpus num %s", vcpus_num)
+            if (vcpus_num % 2 != 0):
+                vcpus_num += 1
+            vm_xml.VMXML.new_from_inactive_dumpxml(vm.name).set_vm_vcpus(vm.name, vcpus_num, vcpus_num, topology_correction=True)
+            LOG.debug("vmxml for %s: %s", vm.name, vm.get_xml())
+
+
+        # Start stress workload on the host
+        # utils_test.load_stress("stress_on_host", params=params)
+
+
+        # Start all vms and verify vms could be logged in normally
+        for vm in vms:
+            LOG.debug("state before login %s", vm.state())
+            vm.prepare_guest_agent()
+            vm.wait_for_login()
+            LOG.debug("state afer login %s", vm.state())
+
+
+
+        # Verify all vms could be gracefully shutdown successfully
+        for vm in vms:
+            vm.wait_for_shutdown()
+            LOG.debug("state after shutdown %s", vm.state())
+
+
+
+    finally:
+        LOG.info("in finally")
+        # # Recover VM
+        # for i, vm in enumerate(vms):
+        #     if vm.is_alive():
+        #         vm.destroy(gracefully=False)
+        #     LOG.info("Restoring vm %s...", vm.name)
+        #     vmxml_backup[i].sync()
\ No newline at end of file