    def test_embedding_concurrent_multi_threads(self, pipeline_model, embedding_size):
        """
        target: test embedding for normal case
        method:  embedding with concurrent multi-processes
        expected: return embeddings
        """
        threads_num = 10
        threads = []
        emb_conf = AutoConfig.load_config(pipeline_name)
        emb_conf.model = pipeline_model
        emb_pipe = AutoPipes.pipeline(pipeline_name, emb_conf)

        def embedding():
            embeddings = emb_pipe(data_path + "towhee_test_image2.jpg").to_list()[0][0].tolist()
            assert len(embeddings) == embedding_size

        for i in range(threads_num):
            t = threading.Thread(target=embedding)
            threads.append(t)
            t.start()
            time.sleep(0.2)
        for t in threads:
            t.join()
        return True
target: test embedding for normal case
method:  embedding with concurrent multi-processes
expected: return embeddings
tests/testcases/test_image_embedding.py