add mutex lock

Makefile

@@ -24,15 +24,15 @@ v=debug
 include co.mk
 
 ########## options ##########
-#CFLAGS += -g -fno-strict-aliasing -O2 -Wall -export-dynamic \
-#	-Wall -pipe  -D_GNU_SOURCE -D_REENTRANT -fPIC -Wno-deprecated -m64
+CFLAGS += -g -fno-strict-aliasing -O2 -Wall -export-dynamic \
+	-Wall -pipe  -D_GNU_SOURCE -D_REENTRANT -fPIC -Wno-deprecated -m64
 
-LINKS += -g -L./lib -lcolib -lpthread -ldl
+LINKS += -g -L./lib -lcolib -lpthread -ldl 
 
 COLIB_OBJS=co_epoll.o co_routine.o co_hook_sys_call.o coctx_swap.o coctx.o
 #co_swapcontext.o
 
-PROGS = colib example_poll example_echosvr example_echocli example_thread  example_cond example_specific example_copystack
+PROGS = colib example_poll example_echosvr example_echocli example_thread  example_cond example_specific example_copystack example_closure
 
 all:$(PROGS)
 
@@ -61,6 +61,8 @@ example_copystack:example_copystack.o
 	$(BUILDEXE)
 example_setenv:example_setenv.o
 	$(BUILDEXE)
+example_closure:example_closure.o
+	$(BUILDEXE)
 
 dist: clean libco-$(version).src.tar.gz
 

example_closure.cpp

@@ -30,16 +30,20 @@ int main( int argc,char *argv[] )
 {
 	vector< stCoClosure_t* > v;
 
+	pthread_mutex_t m = PTHREAD_MUTEX_INITIALIZER;
+
 	int total = 100;
 	vector<int> v2;
-	co_ref( ref,total,v2 );
+	co_ref( ref,total,v2,m);
 	for(int i=0;i<10;i++)
 	{
 		co_func( f,ref,i )
 		{
 			printf("ref.total %d i %d\n",ref.total,i );
 			//lock
+			pthread_mutex_lock(&ref.m);
 			ref.v2.push_back( i );
+			pthread_mutex_unlock(&ref.m);
 			//unlock
 		}
 		co_func_end;