| 537 | } |
| 538 | |
| 539 | void WorkThread::doKeyListWork() |
| 540 | { |
| 541 | if(!prepare()) { |
| 542 | emit runError(_taskMsg->_taskid,_string); |
| 543 | emit finishWork(_taskMsg->_taskid); |
| 544 | return; |
| 545 | } |
| 546 | |
| 547 | _sendMsg = *_taskMsg; |
| 548 | _sendMsg._list.clear(); |
| 549 | _sendMsg._respResult.init(); |
| 550 | do { |
| 551 | if(_redisClient->scan(_sendMsg._keyPattern, _sendMsg._respResult, _cursor, BATCH_SCAN_NUM)) { |
| 552 | _cursor = _sendMsg._respResult._arrayValue[0]._stringValue.toLongLong(); |
| 553 | emit sendData(_sendMsg); |
| 554 | } else { |
| 555 | _cursor = 0; |
| 556 | } |
| 557 | _sendMsg._respResult.init(); |
| 558 | } while(_cursor); |
| 559 | |
| 560 | destroy(); |
| 561 | } |
| 562 | |
| 563 | void WorkThread::doValueListWork() { |
| 564 | |