diff --git a/spring-cloud-function-context/src/main/java/org/springframework/cloud/function/context/catalog/SimpleFunctionRegistry.java b/spring-cloud-function-context/src/main/java/org/springframework/cloud/function/context/catalog/SimpleFunctionRegistry.java
index 49fa1866a..a474d81c9 100644
--- a/spring-cloud-function-context/src/main/java/org/springframework/cloud/function/context/catalog/SimpleFunctionRegistry.java
+++ b/spring-cloud-function-context/src/main/java/org/springframework/cloud/function/context/catalog/SimpleFunctionRegistry.java
@@ -278,7 +278,7 @@ public class SimpleFunctionRegistry implements FunctionRegistry, FunctionInspect
 	/*
 	 *
 	 */
-	private FunctionInvocationWrapper compose(Class<?> type, String functionDefinition) {
+	private synchronized FunctionInvocationWrapper compose(Class<?> type, String functionDefinition) {
 		String[] functionNames = StringUtils.delimitedListToStringArray(functionDefinition.replaceAll(",", "|").trim(), "|");
 		FunctionInvocationWrapper composedFunction = null;