Examples of wait()


Examples of org.apache.pig.penny.impl.comm.SyncCallResult.wait()

        messagingClientHandler.addOutstandingAck(m.getAck(), scr);
        synchronized(scr) {
            sendAsync(m);
            while(scr.getException() == null && scr.getTuple() == null) {
                try {
                    scr.wait();
                } catch(InterruptedException e) {
                    throw new InterruptedIOException();
                }
            }
        }

Examples of org.apache.pivot.util.concurrent.TaskGroup.wait()

        });

        synchronized(queryGroup) {
            if (queryGroup.isPending()) {
                try {
                    queryGroup.wait(10000);
                } catch(InterruptedException exception) {
                    throw new RuntimeException(exception);
                }
            }
        }

Examples of org.apache.tajo.QueryId.wait()

    QueryMasterRunner queryMasterRunner = new QueryMasterRunner(queryId, queryMasterManagerAddr);
    queryMasterRunner.init(conf);
    queryMasterRunner.start();

    synchronized(queryId) {
      queryId.wait();
    }

    System.exit(0);
  }

Examples of org.apache.uima.aae.InProcessCache.wait()

        }
        else
        {
          synchronized (cache)
          {
            cache.wait(10);
          }
        }
      }
    }
    catch ( Exception e)

Examples of org.apache.uima.aae.controller.Endpoint.wait()

          // the destination object ( a temp queue) for the
          // delegate to reply to.
          while (!endpoint.replyDestinationFailed() && endpoint.getDestination() == null) {
            synchronized (endpoint) {
              try {
                endpoint.wait(200);
              } catch (InterruptedException e) {
              }
            }
          }
         

Examples of org.apache.uima.adapter.jms.activemq.SpringContainerDeployer.wait()

    while (!springDeployer.isInitialized() ) {
      if ( springDeployer.initializationFailed()) {
        throw new ResourceInitializationException();
      }
      synchronized (springDeployer) {
        springDeployer.wait(100);
      }
    }
    // Check if the deployer failed
    // Register this class to receive Spring container notifications. Specifically, looking
    // for an even signaling the container termination. This is done so that we can stop

Examples of org.apache.uima.adapter.jms.client.BaseUIMAAsynchronousEngine_impl.wait()

                System.out.println("Client Received Expected Error on CAS:"+(i+1));
              } finally {
                cas.release();
              }
              synchronized(uimaAsEngine) {
                uimaAsEngine.wait(100);
              }
            }
            System.out.println("Thread:"+Thread.currentThread().getId()+" Completed run()");
            uimaAsEngine.stop();
          } catch( Exception e) {

Examples of org.apache.uima.collection.impl.cpm.container.ServiceProxyPool.wait()

                      CPMUtils.CPM_LOG_RESOURCE_BUNDLE,
                      "UIMA_CPM_wait_for_service_proxy_pool__FINEST",
                      new Object[] { Thread.currentThread().getName(),
                          aProcessingContainer.getName() });
            }
            pool.wait()// pool has notifyall when it changes the pool.getSize() result
          } catch (Exception e) {
          }
        }
        CasProcessor cProcessor = pool.checkOut();
        if (cProcessor != null && cProcessor instanceof CasObjectNetworkCasProcessorImpl) {

Examples of org.apache.zookeeper.server.ZooKeeperServer.wait()

            {
                synchronized ( zkServer )
                {
                    if ( !zkServer.isRunning() )
                    {
                        zkServer.wait();
                    }
                }
            }
        }
    }

Examples of org.corrib.s3b.sscf.exports.BookmarksExport.wait()

        BookmarksExport be = BookmarksExport.getBookmarksExport(user, bs,serviceAddr);

        synchronized(be){
          be.submitPosts(posts);
          try {
            be.wait();
          } catch (InterruptedException e) {
            logger.severe(e.getMessage());
          }
        }
        //change state of exported resources
TOP
Copyright © 2018 www.massapi.com. All rights reserved.
All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.