diff options
author | gmcdonald | 2010-02-13 01:32:03 +0000 |
---|---|---|
committer | gmcdonald | 2010-02-13 01:32:03 +0000 |
commit | 0425aadc78680e53000fd0108b540d6eca048516 (patch) | |
tree | 8ec7ab8e015d454c5ec586dfc91e05a2dce1cfc0 /util/src/thread_pool.c | |
download | axis2c-0425aadc78680e53000fd0108b540d6eca048516.tar.gz axis2c-0425aadc78680e53000fd0108b540d6eca048516.tar.bz2 |
Moving axis svn, part of TLP move INFRA-2441
git-svn-id: http://svn.apache.org/repos/asf/axis/axis2/c/core/trunk@909681 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'util/src/thread_pool.c')
-rw-r--r-- | util/src/thread_pool.c | 147 |
1 files changed, 147 insertions, 0 deletions
diff --git a/util/src/thread_pool.c b/util/src/thread_pool.c new file mode 100644 index 0000000..cf1078d --- /dev/null +++ b/util/src/thread_pool.c @@ -0,0 +1,147 @@ +/* + * Licensed to the Apache Software Foundation (ASF) under one or more + * contributor license agreements. See the NOTICE file distributed with + * this work for additional information regarding copyright ownership. + * The ASF licenses this file to You under the Apache License, Version 2.0 + * (the "License"); you may not use this file except in compliance with + * the License. You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ + +#include <axutil_thread_pool.h> +#include <axutil_env.h> +#include <axutil_error_default.h> + +struct axutil_thread_pool +{ + axutil_allocator_t *allocator; +}; + +AXIS2_EXTERN axutil_thread_pool_t *AXIS2_CALL +axutil_thread_pool_init( + axutil_allocator_t *allocator) +{ + axutil_thread_pool_t *pool = NULL; + + pool = (axutil_thread_pool_t *)AXIS2_MALLOC(allocator, sizeof(axutil_thread_pool_t)); + + if(!pool) + { + return NULL; + } + pool->allocator = allocator; + + return pool; +} + +AXIS2_EXTERN void AXIS2_CALL +axutil_thread_pool_free( + axutil_thread_pool_t *pool) +{ + if(!pool) + { + return; + } + if(!pool->allocator) + { + return; + } + AXIS2_FREE(pool->allocator, pool); + return; +} + +AXIS2_EXTERN axutil_thread_t *AXIS2_CALL +axutil_thread_pool_get_thread( + axutil_thread_pool_t *pool, + axutil_thread_start_t func, + void *data) +{ + if(!pool) + { + return NULL; + } + if(!pool->allocator) + { + return NULL; + } + return axutil_thread_create(pool->allocator, NULL, func, data); +} + +AXIS2_EXTERN axis2_status_t AXIS2_CALL +axutil_thread_pool_join_thread( + axutil_thread_pool_t *pool, + axutil_thread_t *thd) +{ + if(!pool || !thd) + { + return AXIS2_FAILURE; + } + return axutil_thread_join(thd); +} + +AXIS2_EXTERN axis2_status_t AXIS2_CALL +axutil_thread_pool_exit_thread( + axutil_thread_pool_t *pool, + axutil_thread_t *thd) +{ + if(!pool || !thd) + { + return AXIS2_FAILURE; + } + return axutil_thread_exit(thd, pool->allocator); +} + +AXIS2_EXTERN axis2_status_t AXIS2_CALL +axutil_thread_pool_thread_detach( + axutil_thread_pool_t *pool, + axutil_thread_t *thd) +{ + if(!pool || !thd) + { + return AXIS2_FAILURE; + } + return axutil_thread_detach(thd); +} + +AXIS2_EXTERN axutil_env_t *AXIS2_CALL +axutil_init_thread_env( + const axutil_env_t *system_env) +{ + axutil_allocator_t * allocator = NULL; + axutil_error_t *error = NULL; + allocator = axutil_allocator_clone(system_env->allocator); + error = axutil_error_create(allocator); + return axutil_env_create_with_error_log_thread_pool(allocator, error, system_env->log, + system_env-> thread_pool); +} + +AXIS2_EXTERN void AXIS2_CALL +axutil_free_thread_env( + struct axutil_env *thread_env) +{ + if(!thread_env) + { + return; + } + + if(--(thread_env->ref) > 0) + { + return; + } + + /* log, thread_pool and allocator are shared, so do not free them */ + thread_env->log = NULL; + thread_env->thread_pool = NULL; + if(thread_env->error) + { + AXIS2_ERROR_FREE(thread_env->error); + } + AXIS2_FREE(thread_env->allocator, thread_env); +} |