breeze/workflow
1
0
Fork 0
mirror of https://github.com/sogou/workflow.git synced 2026-02-08 01:33:17 +08:00
Code Issues Packages Projects Releases Wiki Activity

Merge branch 'master' of https://github.com/sogou/workflow into nossl

Browse Source
This commit is contained in:
Xie Han
2023-11-15 21:04:17 +08:00
parent 5383833783 507ad89220
commit 82c629e178
1 changed files with 15 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

19
src/kernel/Executor.cc
View File

@@ -78,12 +78,24 @@ void Executor::executor_thread_routine(void *context)
ExecQueue *queue = (ExecQueue *)context;
struct ExecSessionEntry *entry;
ExecSession *session;
int empty;
pthread_mutex_lock(&queue->mutex);
entry = list_entry(queue->session_list.next, struct ExecSessionEntry, list);
list_del(&entry->list);
if (entry->list.next == &queue->session_list)
{
pthread_mutex_lock(&queue->mutex);
list_del(&entry->list);
empty = list_empty(&queue->session_list);
pthread_mutex_unlock(&queue->mutex);
}
else
{
list_del(&entry->list);
empty = 0;
}
session = entry->session;
if (!list_empty(&queue->session_list))
if (!empty)
{
struct thrdpool_task task = {
.routine = Executor::executor_thread_routine,
@@ -94,7 +106,6 @@ void Executor::executor_thread_routine(void *context)
else
free(entry);
pthread_mutex_unlock(&queue->mutex);
session->execute();
session->handle(ES_STATE_FINISHED, 0);
}