diff --git a/HISTORY b/HISTORY
index e68c91b..e8bd699 100644
--- a/HISTORY
+++ b/HISTORY
@@ -1,6 +1,7 @@
 
-Version 1.42  2019-11-30
+Version 1.42  2019-12-03
   * add function get_gzip_command_filename
+  * function create_work_threads changed
 
 Version 1.41  2019-09-30
   * change CIDR network_bits range from [16, 32) to [10, 32)
diff --git a/src/pthread_func.c b/src/pthread_func.c
index 9182b93..a66bd10 100644
--- a/src/pthread_func.c
+++ b/src/pthread_func.c
@@ -136,11 +136,12 @@ int init_pthread_attr(pthread_attr_t *pattr, const int stack_size)
 	return 0;
 }
 
-int create_work_threads(int *count, void *(*start_func)(void *), \
-		void *arg, pthread_t *tids, const int stack_size)
+int create_work_threads(int *count, void *(*start_func)(void *),
+		void **args, pthread_t *tids, const int stack_size)
 {
 	int result;
 	pthread_attr_t thread_attr;
+    void **current_arg;
 	pthread_t *ptid;
 	pthread_t *ptid_end;
 
@@ -151,16 +152,16 @@ int create_work_threads(int *count, void *(*start_func)(void *), \
 
 	result = 0;
 	ptid_end = tids + (*count);
-	for (ptid=tids; ptid<ptid_end; ptid++)
+	for (ptid=tids,current_arg=args; ptid<ptid_end; ptid++,current_arg++)
 	{
-		if ((result=pthread_create(ptid, &thread_attr, \
-			start_func, arg)) != 0)
+		if ((result=pthread_create(ptid, &thread_attr,
+			start_func, *current_arg)) != 0)
 		{
 			*count = ptid - tids;
-			logError("file: "__FILE__", line: %d, " \
-				"create thread failed, startup threads: %d, " \
-				"errno: %d, error info: %s", \
-				__LINE__, *count, \
+			logError("file: "__FILE__", line: %d, "
+				"create threads #%d fail, "
+				"errno: %d, error info: %s",
+				__LINE__, *count,
 				result, STRERROR(result));
 			break;
 		}
diff --git a/src/pthread_func.h b/src/pthread_func.h
index 9e6db86..f7f1a33 100644
--- a/src/pthread_func.h
+++ b/src/pthread_func.h
@@ -24,8 +24,8 @@ extern "C" {
 int init_pthread_lock(pthread_mutex_t *pthread_lock);
 int init_pthread_attr(pthread_attr_t *pattr, const int stack_size);
 
-int create_work_threads(int *count, void *(*start_func)(void *), \
-		void *arg, pthread_t *tids, const int stack_size);
+int create_work_threads(int *count, void *(*start_func)(void *),
+		void **args, pthread_t *tids, const int stack_size);
 int kill_work_threads(pthread_t *tids, const int count);
 
 #ifdef __cplusplus