Unlock 30% off on Manual Testing Annual Plans this Holiday Season.

Copied to Clipboard!

How to use _worker method in ATX

Best Python code snippet using ATX

CreateMultipleOrderedEC.py

Source:CreateMultipleOrderedEC.py

1#!/usr/bin/env python2# -*- coding: utf-8 -*-3##4#   @file CreateMultipleOrderedEC.py5#   @brief å®è¡é åºã®è¨å®ãã§ããå®è¡ã³ã³ããã¹ã6import threading7import time8import OpenRTM_aist9from MPTask import MPTask,GUITask10import MPComp11pyqtExist = True12try:13    from PyQt4 import QtCore, QtGui14except:15    pyqtExist = False16##17# @class MultipleOrderedEC18# @brief å®è¡é åºã®è¨å®ãã§ããå®è¡ã³ã³ããã¹ã19#20class MultipleOrderedEC(OpenRTM_aist.PeriodicExecutionContext):21    ##22    # @brief ã³ã³ã¹ãã©ã¯ã¿23    # @param self 24    def __init__(self):25        26        OpenRTM_aist.PeriodicExecutionContext.__init__(self)27        28        29        30        self._rtcout = OpenRTM_aist.Manager.instance().getLogbuf("rtobject.mp_ec")31        self.prop = OpenRTM_aist.Manager.instance().getConfig()32        #print OpenRTM_aist.Manager.instance().getConfig()33        self.SetGui = "YES"34        self.FileName = ""35        #self.DebugFlag = ""36        self.SetGui = self.getProperty(self.prop, "exec_cxt.periodic.gui", self.SetGui)37        #print self.SetGui38        self.FileName = self.getProperty(self.prop, "exec_cxt.periodic.filename", self.FileName)39        #print self.FileName40        #self.DebugFlag = self.getProperty(self.prop, "exec_cxt.periodic.debug", self.DebugFlag)41        42        self.rs = []43        self.r_num = 044        45        46        self.SetGui = [self.SetGui]47        OpenRTM_aist.eraseBlank(self.SetGui)48        self.SetGui = self.SetGui[0]49        self.FileName = [self.FileName]50        OpenRTM_aist.eraseBlank(self.FileName)51        self.FileName = self.FileName[0]52        53        #self.DebugFlag = [self.DebugFlag]54        #OpenRTM_aist.eraseBlank(self.DebugFlag)55        #self.DebugFlag = self.DebugFlag[0]56        self._mutex_del2 = threading.RLock()57        if self.SetGui == "YES":58            #print pyqtExist59            if pyqtExist:60                self.g_task = GUITask(self)61                self.g_task.activate()62        self.nameList = []63        self.comp_t = []64    65    ##66    # @brief rtc.confã®è¨å®ãåå¾ããé¢æ°67    # @param self 68    # @param prop ããããã£69    # @param key ãã¼70    # @param value å¤71    # @return å¤72    def getProperty(self, prop, key, value):73        74        if  prop.findNode(key) != None:75            #print value76            value = prop.getProperty(key)77        return value78          79    ##80    # @brief RTCã®ãªã¹ãæ´æ°81    # @param self 82    def Update_Name(self):83        self._worker.updateComponentList()84        85        if self.comp_t == self._worker._comps:86            pass87        else:88            guard2 = OpenRTM_aist.ScopedLock(self._mutex_del2)89            self.comp_t = []90            self.nameList = []91            for i in range(0, len(self._worker._comps)):92                self.comp_t.append(self._worker._comps[i])93                self._worker._comps[i].i_name = self._worker._comps[i]._rtobj.get_component_profile().instance_name94                #self.nameList.append(self._worker._comps[i]._sm._obj.get_component_profile().instance_name)95            del guard296    97    ##98    # @brief çªå·ããã³ã³ãã¼ãã³ãã®åååå¾ã®é¢æ°99    # @param self100    # @param num çªå·101    # @return RTCå102    def getCompName(self, num):103        104        self.Update_Name()105        106        107        #guard2 = OpenRTM_aist.ScopedLock(self._mutex_del2)108        #Name = self._worker._comps[num]._sm._obj.get_component_profile().instance_name109        #del guard2110        #Name = self.nameList[num]111        Name = self._worker._comps[num].i_name112        return Name113    114    ##115    # @brief ã³ã³ãã¼ãã³ãã®æ°åå¾ã®é¢æ°116    # @param self117    # @return RTCæ°118    def getCompNum(self):119        return len(self._worker._comps)120    121    ##122    # @brief ã³ã³ãã¼ãã³ãã®ãã¸ãã¯å®è¡ã®é¢æ°123    # @param self124    # @param c ãããã¯125    def workerComp(self, c):126        sd = c.r in self._worker._comps127        128        #if self.DebugFlag == "YES":129        #    print c.v130        #print c.v, c.r131        if sd == True:132            #t0_ = OpenRTM_aist.Time()133            c.r._sm.worker()134            #t1_ = OpenRTM_aist.Time()135            #print c.v,(t1_ - t0_).getTime().toDouble()136        else:137            138            for i in range(0, len(self._worker._comps)):139                if c.v == self.getCompName(i):140                    c.r = self._worker._comps[i]141                    self._worker._comps[i]._sm.worker()142    143    ##144    # @brief è¨å®ããå®è¡é åºã®RTCãæ ¼ç´ããé¢æ°145    # @param self146    def LoadRules(self):147        for h in range(0, len(self.rs)):148            for i in range(0, len(self.rs[h].ar)):149                for j in range(0, len(self._worker._comps)):150                    151                    #Name = self._worker._comps[j]._sm._obj.get_component_profile().instance_name152                    Name = self.getCompName(j)153                    if Name == self.rs[h].ar[i].name:154                        self.rs[h].ar[i].r = self._worker._comps[j]155            for i in range(0, len(self.rs[h].rs)):156                for j in range(0, len(self.rs[h].rs[i].SR)):157                    for k in range(0, len(self.rs[h].rs[i].SR[j])):158                        159                        for l in range(0, len(self._worker._comps)):160                            #Name = self._worker._comps[l]._sm._obj.get_component_profile().instance_name161                            Name = self.getCompName(l)162                            if Name == self.rs[h].rs[i].SR[j][k].v:163                                164                                self.rs[h].rs[i].SR[j][k].r = self._worker._comps[l]165        166    167    ##168    # @brief GUIããå®è¡é åºã®èªã¿è¾¼ã¿ã®é¢æ°169    # @param self170    # @param RS_d å®è¡é åºã®ãªã¹ã171    def LoadRuleGUI(self, RS_d):172        guard = OpenRTM_aist.ScopedLock(self._workerthread._mutex)173        self.rs = []174        self.rs = RS_d175        176        177        self.LoadRules()178        del guard179  180    181    ##182    # @brief ãã¡ã¤ã«ããå®è¡é åºã®èªã¿è¾¼ã¿ã®é¢æ°183    # @param self184    def LoadRule(self):185        186        187        guard = OpenRTM_aist.ScopedLock(self._workerthread._mutex)188        189        190        191        192        for h in range(0, len(self.rs)):193                self.rs[h].rs = []194        self.rs = []195        MPComp.LoadMainRule(self.rs, self.FileName)196        self.LoadRules()197        198        del guard199    200    ##201    # @brief ã¹ã¬ããå®è¡é¢æ°202    # @param self203    # @return 0204    def svc(self):205        self._rtcout.RTC_TRACE("svc()")206        #flag = True207        count_ = 0208        self.LoadRule()209        210    211        212        #while flag:213        while self.threadRunning():214            215            guard = OpenRTM_aist.ScopedLock(self._workerthread._mutex)216            #self.LoadRules()217            #self._worker._cond.acquire()218            #while not self._worker._running:219            #    self._worker._cond.wait()220            221            while not self._workerthread._running:222                self._workerthread._cond.wait()223            self._worker.updateComponentList()224            t0_ = OpenRTM_aist.Time()225            if self._worker._running:226                227                for i in range(0, len(self.rs)):228                    S = True229                    for j in range(0, len(self.rs[i].ar)):230                        231                        Flag = False232                        for k in range(0, len(self._worker._comps)):233                            if self.rs[i].ar[j].r == self._worker._comps[k]:234                                235                                if self.rs[i].ar[j].state == -1:236                                    237                                    pass238                                else:239                                    if self.rs[i].ar[j].state != self._worker._comps[k]._sm.get_state():240                                        S = False241                        if Flag == False:242                            for k in range(0, len(self._worker._comps)):243                                if self.getCompName(k) == self.rs[i].ar[j].name:244                                    self.rs[i].ar[j].r = self._worker._comps[k]245                                    if self.rs[i].ar[j].state == -1:246                                        pass247                                    else:248                                        if self.rs[i].ar[j].state != self._worker._comps[k]._sm.get_state():249                                            S = False250                    if S == True:251                        self.r_num = i252                        break253                        254                if self.r_num < len(self.rs):255                    256                    for i in range(0, len(self.rs[self.r_num].rs)):257                        258                        if len(self.rs[self.r_num].rs[i].SR) == 0:259                            pass260                        elif len(self.rs[self.r_num].rs[i].SR) == 1:261                            262                            for j in range(0, len(self.rs[self.r_num].rs[i].SR[0])):263                                self.rs[self.r_num].rs[i].SR[0][j].s = 1264                                """sd = self.rs[self.r_num].rs[i].SR[0][j].r in self._worker._comps265                                print self.rs[self.r_num].rs[i].SR[0][j].v,self.rs[self.r_num].rs[i].SR[0][j].r266                                if sd == True:267                                    self.rs[self.r_num].rs[i].SR[0][j].r._sm.worker()"""268                                self.workerComp(self.rs[self.r_num].rs[i].SR[0][j])269                                self.rs[self.r_num].rs[i].SR[0][j].s = 0270                        else:271                                272                               p_num = len(self.rs[self.r_num].rs[i].SR)273                               m_task = []274                               for j in range(0, p_num):275                                   m_task_s = MPTask(self)276                                   m_task.append(m_task_s)277                                   for k in range(0, len(self.rs[self.r_num].rs[i].SR[j])):278                                       m_task_s.addComp(self.rs[self.r_num].rs[i].SR[j][k],i,j,k)279                                   m_task_s.activate()280                               for j in range(0, p_num):281                                   m_task[j].wait()282                                   m_task[j].close()283            284                285            286            #self._worker._cond.release()287            del guard288            t1_ = OpenRTM_aist.Time()289            period_ = self.getPeriod()290            if count_ > 1000:291                exctm_ = (t1_ - t0_).getTime().toDouble()292                #slptm_ = self._period.toDouble() - exctm_293                slptm_ = period_.toDouble() - exctm_294                self._rtcout.RTC_PARANOID("Period:    %f [s]", period_.toDouble())295                self._rtcout.RTC_PARANOID("Execution: %f [s]", exctm_)296                self._rtcout.RTC_PARANOID("Sleep:     %f [s]", slptm_)297            t2_ = OpenRTM_aist.Time()298            if not self._nowait and period_.toDouble() > ((t1_ - t0_).getTime().toDouble()):299                if count_ > 1000:300                    self._rtcout.RTC_PARANOID("sleeping...")301                slptm_ = period_.toDouble() - (t1_ - t0_).getTime().toDouble()302                time.sleep(slptm_)303            if count_ > 1000:304                t3_ = OpenRTM_aist.Time()305                self._rtcout.RTC_PARANOID("Slept:     %f [s]", (t3_ - t2_).getTime().toDouble())306                count_ = 0307            count_ += 1308            #flag = self._running309        310        return 0311    312  313##314# @brief å®è¡ã³ã³ããã¹ãåæåé¢æ°315# @param manager ããã¼ã¸ã£ãªãã¸ã§ã¯ã316def MultipleOrderedECInit(manager):317  318  OpenRTM_aist.ExecutionContextFactory.instance().addFactory("MultipleOrderedEC",319                            MultipleOrderedEC,320                            OpenRTM_aist.ECDelete)...

progress_dialog.py

Source:progress_dialog.py

1# -*- coding: utf-8 -*-2#3# Copyright (C) 2014 GNS3 Technologies Inc.4#5# This program is free software: you can redistribute it and/or modify6# it under the terms of the GNU General Public License as published by7# the Free Software Foundation, either version 3 of the License, or8# (at your option) any later version.9#10# This program is distributed in the hope that it will be useful,11# but WITHOUT ANY WARRANTY; without even the implied warranty of12# MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the13# GNU General Public License for more details.14#15# You should have received a copy of the GNU General Public License16# along with this program.  If not, see <http://www.gnu.org/licenses/>.17"""18Progress dialog that blocking tasks (file operations, network connections etc.)19"""20from ..qt import sip21from gns3.version import __version__22from ..qt import QtWidgets, QtCore, qslot23import logging24log = logging.getLogger(__name__)25class ProgressDialog(QtWidgets.QProgressDialog):26    """27    Progress dialog implementation with thread support.28    :param thread: thread to run29    :param title: window title30    :param label_text: text to describe the progress bar31    :param cancel_button_text: text for the cancel button32    :param busy: if True, the progress bar in "sliding mode"33    :param delay: Countdown in seconds before starting the worker34    :param create_thread: Start the worker in a dedicated thread35    to show unknown progress.36    :param parent: parent widget37    """38    def __init__(self, worker, title, label_text, cancel_button_text, busy=False, parent=None, delay=0, create_thread=True, cancelable=False):39        if "dev" in __version__:40            assert QtCore.QThread.currentThread() == QtWidgets.QApplication.instance().thread()41        minimum = 042        maximum = 10043        if busy:44            maximum = 045        super().__init__(label_text, cancel_button_text, minimum, maximum, parent)46        self.setModal(True)47        self.setAttribute(QtCore.Qt.WA_DeleteOnClose, True)48        self._errors = []49        self.setWindowTitle(title)50        self.canceled.connect(self._canceledSlot)51        self.destroyed.connect(self._cleanup)52        self._cancelable = cancelable53        self._worker = worker54        self._worker.setObjectName(worker.__class__.__name__)55        if create_thread:56            self._thread = QtCore.QThread()57            if "dev" in __version__:58                assert not self._worker.parent()59            log.debug("Set worker inside a thread {}".format(self._worker.__class__))60            self._worker.moveToThread(self._thread)61        else:62            log.debug("Set worker outside of a thread {}".format(self._worker.__class__))63            self._thread = None64        self._worker.finished.connect(self.accept)65        self._worker.updated.connect(self._updateProgressSlot)66        self._worker.error.connect(self._error)67        if self._thread:68            self._thread.started.connect(self._worker.run)69        self._countdownTimer = None70        if delay == 0:71            self._start()72        else:73            self._delay = delay74            self._countdownTimer = QtCore.QTimer()75            self._countdownTimer.setInterval(self._delay * 100)76            self._countdownTimer.timeout.connect(self._updateCountdownSlot)77            self._countdownTimer.start()78            self._updateCountdownSlot()79    @qslot80    def _updateCountdownSlot(self):81        """82        Called every second for countdown before83        starting the worker84        """85        if self._delay <= 0:86            self.setCancelButtonText("Cancel")87            self._countdownTimer.stop()88            self._start()89        else:90            self.setCancelButtonText("Cancel start ({} seconds)".format(self._delay))91            self._delay -= 192    def _start(self):93        #  connect the thread signals and start the thread94        if self._thread:95            self._thread.start()96            log.debug("{} thread started".format(self._worker.objectName()))97        elif self._worker:98            self._worker.run()99    @qslot100    def _canceledSlot(self):101        if self._cancelable and not self._thread:102            self._worker.cancel()103            log.debug("{} worker canceled".format(self._worker.objectName()))104        if self._thread:105            self._worker.cancel()106            log.debug("{} thread canceled".format(self._worker.objectName()))107        self._cleanup()108    @qslot109    def accept(self):110        if self._worker:111            log.debug("{} thread finished".format(self._worker.objectName()))112        self._cleanup()113        super().accept()114    def __del__(self):115        self._cleanup()116    @qslot117    def _cleanup(self):118        """119        Delete the thread.120        """121        if self._countdownTimer:122            self._countdownTimer.stop()123        if self._thread and not sip.isdeleted(self._thread):124            if self._thread.isRunning():125                log.debug("{} thread is being destroyed".format(self._worker.objectName()))126                thread = self._thread127                self._thread = None128                thread.quit()129                if not thread.wait(3000):130                    thread.terminate()131                    thread.wait()132                log.debug("{} thread destroyed".format(self._worker.objectName()))133                thread.deleteLater()134            self._worker = None135    @qslot136    def _updateProgressSlot(self, value):137        """138        Slot to update the progress bar value.139        :param value: value for the progress bar (integer)140        """141        if self._thread:142            # It seems in some cases this is called on a deleted object and crash143            self.setValue(value)144    @qslot145    def _error(self, message, stop=False):146        """147        Slot to show an error message sent by the thread.148        :param message: message149        """150        if stop:151            log.critical("{} thread stopping with an error: {}".format(self._worker.objectName(), message))152            self._canceledSlot()153            QtWidgets.QMessageBox.critical(self.parentWidget(), "Error", "{}".format(message))154        else:155            self._errors.append(message)156            self._cleanup()157    def errors(self):158        """159        Returns error messages.160        :returns: error message list161        """...

testWorker.py

Source:testWorker.py

1#!/usr/bin/env python2# -*- coding: utf-8 -*-3__author__ = 'Leon'4from unittest import TestCase5from loongtian.util.tasks.tasksManager import *6from loongtian.util.tasks.task import Task,WorkRequest7import loongtian.util.tasks.queue as Queue8class TestWorker(TestCase):9    def setUp(self):10        print ("----setUp----")11        pass # def setUp(self):12    def testWorkerRequest(self):13        print(123)14        print ("----testWorkerRequestæµè¯WorkRequestå·¥ä½é¡¹ï¼å è½½çæ¯å½æ°ï¼----")15        import random16        import time,datetime17        #æµè¯ç¨å½æ°18        def do_work(data):19            time.sleep(2)20            return data+121        #è¿åç»æè°ç¨callback22        def print_result(request,result):23            print ("---Result from request id: %s data: %r time:%s" % (request.id,result,datetime.datetime.now()))24        _worker = TasksManager(3, 'worker1', 1, auto_start =False)25        for i in range(20):#ååå»º20ä¸ªä»»å¡26            req = WorkRequest(do_work,args=[i],kwds={},requestID=i,callback=print_result)27            _worker.addTask(req)28            print ("work request #%s added." % req.id)29        print ('-'*20,'workmanager.threadWorkerSize:', _worker.threadWorkerSize(), '-' * 20)30        #å¼å§æ§è¡ææçå·¥ä½è¯·æ±31        _worker.start()32        print ('-'*20,'after start workmanager.threadWorkerSize:', _worker.threadWorkerSize(), '-' * 20)33        counter = 034        while True:35            try:36                time.sleep(0.5)37                _worker.poll()38                if(counter==5):39                    print ("Add 3 more __threadWorkers threads")40                    _worker.createThreadWorkers(3)41                    print ('-'*20,'after Add 3 more,workmanager.threadWorkerSize:', _worker.threadWorkerSize(), '-' * 20)42                if(counter==10):43                    print ("dismiss 2 __threadWorkers threads")44                    _worker.stopThreadWorkers(2)45                    print ('-'*20,'after dismiss 2,workmanager.threadWorkerSize:', _worker.threadWorkerSize(), '-' * 20)46                if (counter==15):47                    print ("Add 10 more WorkRequest.")48                    for i in range(20,30):#ååå»º10ä¸ªä»»å¡49                        req = WorkRequest(do_work,args=[i],kwds={},requestID=i,callback=print_result)50                        print ("work request #%s added." % req.id)51                        _worker.addTask(req)52                    print (_worker.getThreadWorkersStates())53                    time.sleep(2)54                counter+=155            except NoResultsPending:56                print ("no pending results")57                break58            except Queue.Empty:59                print ('queue empty')60                break61        _worker.stop()62        print ("Stop")63        pass # def testWorkerRequest(self)64    def testWorkerTask(self):65        print ("----testWorkerTaskæµè¯Taskå·¥ä½é¡¹ï¼å è½½çæ¯éè½½çTaskç±»ï¼----")66        #æµè¯ç¨ç±»67        class ComputationTask(Task):68            def __init__(self,id):69                Task.__init__(self,id,id)70                self.inp=id71                # self.callback=print_result72            def start(self):73                time.sleep(0.5) #æ¨¡æä¸ä¸ªå¤§åç¨åºçèæ¶74                self.inp += 175                return  self.inp76        class InitializeTask(Task):77            def start(self):78                for i in range(200):79                    self.workmanager.putTask(ComputationTask, i)80                yield None81        _worker = TasksManager(3, 'worker2', 2, auto_start =False)82        for i in range(50):#ååå»º20ä¸ªä»»å¡83            task=ComputationTask(i)84            _worker.addTask(task)85            print ("ComputationTask #%s added." % task.id)86        print ('-'*20,'workmanager.threadWorkerSize:', _worker.threadWorkerSize(), '-' * 20)87        #å¼å§æ§è¡ææçå·¥ä½è¯·æ±88        _worker.start()89        counter = 090        while True:91            try:92                # time.sleep(0.5)93                _worker.poll()94                if(counter==5):95                    print ("Add 3 more __threadWorkers threads")96                    _worker.createThreadWorkers(3)97                    print ('-'*20,'after Add 3 more,workmanager.threadWorkerSize:', _worker.threadWorkerSize(), '-' * 20)98                if(counter==10):99                    print ("dismiss 2 __threadWorkers threads")100                    _worker.stopThreadWorkers(2)101                    print ('-'*20,'after dismiss 2,workmanager.threadWorkerSize:', _worker.threadWorkerSize(), '-' * 20)102                if (counter==15):103                    print ("Add 10 more ComputationTask.")104                    for i in range(50,60):#ååå»º10ä¸ªä»»å¡105                        task=ComputationTask(i)106                        _worker.addTask(task)107                        print ("ComputationTask #%s added." % task.id)108                    time.sleep(2)109                counter+=1110            except NoResultsPending:111                print ("no pending results")112                break113            except Queue.Empty:114                print ('queue empty')115                break116        _worker.stop()117        print ("Stop")118    def tearDown(self):119        print ("----tearDown----")...

parallel.py

Source:parallel.py

...5__all__ = ['Worker', 'WorkerManager']6class WorkerManager:7    def __init__(self):8        self._manager = mp.Manager()9        self._worker = self.spawn_worker()10    def __del__(self):11        self.disconnect()12    def connect(self):13        self.start_worker()14        while not self._worker.isalive:15            time.sleep(0.01)16    def disconnect(self):17        self.kill_worker()18    #################19    def spawn_worker(self):20        return NotImplemented21    def start_worker(self):22        if self._worker is None:23            self._worker = self.spawn_worker()24        if not self._worker.isalive:25            self._worker.start()26        return 027    def kill_worker(self):28        if self._worker is None:29            return 030        if self._worker.isalive:31            try:32                self._worker.job_Q.put(None)33            except FileNotFoundError:34                sayd('During killing worker, file not found error.')35            except EOFError:36                sayd('During killing worker, EOFError.')37            except BrokenPipeError:38                sayd('During killing worker, BrokenPipeError.')39            self._worker.join()40            self._worker = None41        return 042    def reboot_worker(self):43        self.kill_worker()44        self.start_worker()45    def assign_job_worker(self, job):46        self._worker.job_Q.put(job)47    def receive_result_worker(self):48        return self._worker.result_Q.get()49class Worker(mp.Process):50    def __init__(self, manager):51        super().__init__()52        self.job_Q = manager.Queue()53        self.result_Q = manager.Queue()54        self.status = manager.dict()55        self.status['isalive'] = False56    @property57    def isalive(self):58        try:59            return self.status['isalive']60        except:61            return False...

Automation Testing Tutorials

Learn to execute automation testing from scratch with LambdaTest Learning Hub. Right from setting up the prerequisites to run your first automation test, to following best practices and diving deeper into advanced test scenarios. LambdaTest Learning Hubs compile a list of step-by-step guides to help you be proficient with different test automation frameworks i.e. Selenium, Cypress, TestNG etc.