git-svn-id: svn://db.shs.com.ru/pip@279 12ceb7fc-bf1f-11e4-8940-5bc7170c53b5
This commit is contained in:
@@ -127,6 +127,7 @@ private:
|
||||
}
|
||||
if (next_overload && wait_next_pipe) {
|
||||
mutex.unlock();
|
||||
piCoutObj << &next_overload;
|
||||
calculated(last, &next_overload);
|
||||
piMSleep(10);
|
||||
} else {
|
||||
@@ -140,18 +141,19 @@ private:
|
||||
mutex_l.unlock();
|
||||
cnt++;
|
||||
// next_overload = true;
|
||||
piCoutObj << &next_overload;
|
||||
calculated(r, &next_overload);
|
||||
}
|
||||
}
|
||||
}
|
||||
PIQueue<Tin> in;
|
||||
Tout last;
|
||||
PIMutex mutex;
|
||||
PIMutex mutex_l;
|
||||
ullong cnt;
|
||||
uint max_size;
|
||||
bool wait_next_pipe;
|
||||
bool next_overload;
|
||||
uint max_size;
|
||||
ullong cnt;
|
||||
PIQueue<Tin> in;
|
||||
Tout last;
|
||||
};
|
||||
|
||||
#endif // PIPIPELINETHREAD_H
|
||||
|
||||
Reference in New Issue
Block a user