在前面的文章中(http://www.linuxidc.com/Linux/2012-01/51213.htm)所提到的信号转发线程,Attach Listener 线程都只是操作socket文件,并没有去执行比如stack 分析,或者heap的分析,真正的工作线程其实是vm thread.(一)启动vm thread
- jint Threads::create_vm(JavaVMInitArgs* args, bool* canTryAgain) {
- ...
- // Create the VMThread
- { TraceTime timer("Start VMThread", TraceStartupTime);
- VMThread::create();
- Thread* vmthread = VMThread::vm_thread();
-
- if (!os::create_thread(vmthread, os::vm_thread))
- vm_exit_during_initialization("Cannot create VM thread. Out of system resources.");
-
- // Wait for the VM thread to become ready, and VMThread::run to initialize
- // Monitors can have spurious returns, must always check another state flag
- {
- MutexLocker ml(Notify_lock);
- os::start_thread(vmthread);
- while (vmthread->active_handles() == NULL) {
- Notify_lock->wait();
- }
- }
- }
- ...
-
-
- }
我们可以看到,在thread.cpp里启动了线程vm thread,在这里我们同时也稍微的略带的讲一下jvm在linux里如何启动线程的。通常在linux中启动线程,是调用
- int pthread_create((pthread_t *__thread, __const pthread_attr_t *__attr,void *(*__start_routine) (void *), void *__arg));
而在java里却增加了os:create_thread --初始化线程 和os:start_thread--启动线程我们去看一下jvm里面是如何在linux里做到的在os_linux.cpp中来看create_thread的方法
- bool os::create_thread(Thread* thread, ThreadType thr_type, size_t stack_size) {
- ....
- int ret = pthread_create(&tid, &attr, (void* (*)(void*)) java_start, thread);
- ....
- }
继续看java_start方法
- static void *java_start(Thread *thread) {
- ....
- // handshaking with parent thread
- {
- MutexLockerEx ml(sync, Mutex::_no_safepoint_check_flag);
-
- // notify parent thread
- osthread->set_state(INITIALIZED);
- sync->notify_all();
-
- // wait until os::start_thread()
- while (osthread->get_state() == INITIALIZED) {
- sync->wait(Mutex::_no_safepoint_check_flag);
- }
- }
-
- // call one more level start routine
- thread->run();
-
- return 0;
- }
首先jvm先设置了当前线程的状态是Initialized, 然后notify所有的线程, while (osthread->get_state() == INITIALIZED) {
sync->wait(Mutex::_no_safepoint_check_flag);
}不停的查看线程的当前状态是不是Initialized, 如果是的话,调用了sync->wait()的方法等待。来看os:start_thread的方法 os.cpp
- void os::start_thread(Thread* thread) {
- // guard suspend/resume
- MutexLockerEx ml(thread->SR_lock(), Mutex::_no_safepoint_check_flag);
- OSThread* osthread = thread->osthread();
- osthread->set_state(RUNNABLE);
- pd_start_thread(thread);
- }