org.apache.commons.lang3.mutable.MutableBoolean.getValue()方法的使用及代码示例

x33g5p2x  于2022-01-25 转载在 其他  
字(7.8k)|赞(0)|评价(0)|浏览(64)

本文整理了Java中org.apache.commons.lang3.mutable.MutableBoolean.getValue()方法的一些代码示例,展示了MutableBoolean.getValue()的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。MutableBoolean.getValue()方法的具体详情如下:
包路径:org.apache.commons.lang3.mutable.MutableBoolean
类名称:MutableBoolean
方法名:getValue

MutableBoolean.getValue介绍

[英]Gets the value as a Boolean instance.
[中]获取作为布尔实例的值。

代码示例

代码示例来源:origin: neo4j/neo4j

private void logIndexProviderSummary( Map<IndexProviderDescriptor,List<IndexLogRecord>> indexProviders )
{
  Set<String> deprecatedIndexProviders = Arrays.stream( GraphDatabaseSettings.SchemaIndex.values() )
      .filter( GraphDatabaseSettings.SchemaIndex::deprecated )
      .map( GraphDatabaseSettings.SchemaIndex::providerName )
      .collect( Collectors.toSet() );
  StringJoiner joiner = new StringJoiner( ", ", "Deprecated index providers in use: ",
      ". Use procedure 'db.indexes()' to see what indexes use which index provider." );
  MutableBoolean anyDeprecated = new MutableBoolean();
  indexProviders.forEach( ( indexProviderDescriptor, indexLogRecords ) ->
  {
    if ( deprecatedIndexProviders.contains( indexProviderDescriptor.name() ) )
    {
      anyDeprecated.setTrue();
      int numberOfIndexes = indexLogRecords.size();
      joiner.add( indexProviderDescriptor.name() + " (" + numberOfIndexes + (numberOfIndexes == 1 ? " index" : " indexes") + ")" );
    }
  } );
  if ( anyDeprecated.getValue() )
  {
    userLog.info( joiner.toString() );
  }
}

代码示例来源:origin: Netflix/conductor

private boolean verifyTaskInputParameters(ConstraintValidatorContext context, WorkflowDef workflow) {
  MutableBoolean valid = new MutableBoolean();
  valid.setValue(true);
  if (workflow.getTasks() == null) {
    return valid.getValue();
  }
  workflow.getTasks()
      .stream()
      .filter(workflowTask -> workflowTask.getInputParameters() != null)
      .forEach(workflowTask -> {
        List<String> errors = ConstraintParamUtil.validateInputParam(workflowTask.getInputParameters(), workflowTask.getName(), workflow);
        errors.forEach(message -> context.buildConstraintViolationWithTemplate(message).addConstraintViolation());
        if(errors.size() > 0) {
          valid.setValue(false);
        }
      });
  return valid.getValue();
}

代码示例来源:origin: neo4j/neo4j

/**
 * @return true if instantiated tree needs to be rebuilt.
 */
private boolean instantiateTree() throws IOException
{
  monitors.addMonitorListener( treeMonitor() );
  GBPTree.Monitor monitor = monitors.newMonitor( GBPTree.Monitor.class );
  MutableBoolean isRebuilding = new MutableBoolean();
  Header.Reader readRebuilding =
      headerData -> isRebuilding.setValue( headerData.get() == NEEDS_REBUILDING );
  index = new GBPTree<>( pageCache, storeFile, new LabelScanLayout(), pageSize, monitor, readRebuilding,
      needsRebuildingWriter, recoveryCleanupWorkCollector );
  return isRebuilding.getValue();
}

代码示例来源:origin: neo4j/neo4j

@Test
void shouldCatchupRootWhenRootNodeHasTooNewGeneration() throws Exception
{
  // given
  long id = cursor.getCurrentPageId();
  long generation = TreeNode.generation( cursor );
  MutableBoolean triggered = new MutableBoolean( false );
  Supplier<Root> rootCatchup = () ->
  {
    triggered.setTrue();
    return new Root( id, generation );
  };
  // when
  //noinspection EmptyTryBlock
  try ( SeekCursor<KEY,VALUE> ignored = new SeekCursor<>( cursor, node, key( 0 ), key( 1 ), layout,
      stableGeneration, unstableGeneration, generationSupplier, rootCatchup, generation - 1,
      exceptionDecorator, 1 ) )
  {
    // do nothing
  }
  // then
  assertTrue( triggered.getValue() );
}

代码示例来源:origin: neo4j/neo4j

assertTrue( triggered.getValue() );

代码示例来源:origin: neo4j/neo4j

assertTrue( triggered.getValue() );

代码示例来源:origin: org.apache.commons/commons-lang3

@Test
public void testGetSet() {
  assertFalse(new MutableBoolean().booleanValue());
  assertEquals(Boolean.FALSE, new MutableBoolean().getValue());
  final MutableBoolean mutBool = new MutableBoolean(false);
  assertEquals(Boolean.FALSE, mutBool.toBoolean());
  assertFalse(mutBool.booleanValue());
  assertTrue(mutBool.isFalse());
  assertFalse(mutBool.isTrue());
  mutBool.setValue(Boolean.TRUE);
  assertEquals(Boolean.TRUE, mutBool.toBoolean());
  assertTrue(mutBool.booleanValue());
  assertFalse(mutBool.isFalse());
  assertTrue(mutBool.isTrue());
  mutBool.setValue(false);
  assertFalse(mutBool.booleanValue());
  mutBool.setValue(true);
  assertTrue(mutBool.booleanValue());
  mutBool.setFalse();
  assertFalse(mutBool.booleanValue());
  mutBool.setTrue();
  assertTrue(mutBool.booleanValue());
}

代码示例来源:origin: fr.inria.eventcloud/eventcloud-deployment-cli

@Override
  public void run() {
    String line = null;
    try {
      while ((line = reader.readLine()) != null) {
        if (!servicesDeployed.getValue()
            && line.contains(LOG_MANAGEMENT_WS_DEPLOYED)) {
          servicesDeployed.setValue(true);
          synchronized (servicesDeployed) {
            servicesDeployed.notifyAll();
          }
        }
        System.out.println("ECManagement " + line);
      }
    } catch (IOException ioe) {
      ioe.printStackTrace();
    }
  }
});

代码示例来源:origin: org.neo4j/neo4j-kernel

private void logIndexProviderSummary( Map<IndexProviderDescriptor,List<IndexLogRecord>> indexProviders )
{
  Set<String> deprecatedIndexProviders = Arrays.stream( GraphDatabaseSettings.SchemaIndex.values() )
      .filter( GraphDatabaseSettings.SchemaIndex::deprecated )
      .map( GraphDatabaseSettings.SchemaIndex::providerName )
      .collect( Collectors.toSet() );
  StringJoiner joiner = new StringJoiner( ", ", "Deprecated index providers in use: ",
      ". Use procedure 'db.indexes()' to see what indexes use which index provider." );
  MutableBoolean anyDeprecated = new MutableBoolean();
  indexProviders.forEach( ( indexProviderDescriptor, indexLogRecords ) ->
  {
    if ( deprecatedIndexProviders.contains( indexProviderDescriptor.name() ) )
    {
      anyDeprecated.setTrue();
      int numberOfIndexes = indexLogRecords.size();
      joiner.add( indexProviderDescriptor.name() + " (" + numberOfIndexes + (numberOfIndexes == 1 ? " index" : " indexes") + ")" );
    }
  } );
  if ( anyDeprecated.getValue() )
  {
    userLog.info( joiner.toString() );
  }
}

代码示例来源:origin: fr.inria.eventcloud/eventcloud-deployment-cli

while (!servicesDeployed.getValue()) {
  try {
    servicesDeployed.wait();

代码示例来源:origin: org.apache.bookkeeper/bookkeeper-server

if (isDuplicationFoundAndNotAllowed.getValue()) {
  throw new BookieException.DiskPartitionDuplicationException();

代码示例来源:origin: com.netflix.conductor/conductor-common

private boolean verifyTaskInputParameters(ConstraintValidatorContext context, WorkflowDef workflow) {
  MutableBoolean valid = new MutableBoolean();
  valid.setValue(true);
  if (workflow.getTasks() == null) {
    return valid.getValue();
  }
  workflow.getTasks()
      .stream()
      .filter(workflowTask -> workflowTask.getInputParameters() != null)
      .forEach(workflowTask -> {
        List<String> errors = ConstraintParamUtil.validateInputParam(workflowTask.getInputParameters(), workflowTask.getName(), workflow);
        errors.forEach(message -> context.buildConstraintViolationWithTemplate(message).addConstraintViolation());
        if(errors.size() > 0) {
          valid.setValue(false);
        }
      });
  return valid.getValue();
}

代码示例来源:origin: pl.edu.icm.synat/synat-business-services-impl

@Override
  public boolean hasAcceptableFiles(YElement yElement) {
    
    final MutableBoolean result = new MutableBoolean(false);
    
    ContentBrowser contentBrowser = new ContentBrowser();
    contentBrowser.browse(yElement, new ContentWorker() {
      @Override
      public boolean doInDirectoryRecursively(YContentDirectory directory) {
        return true;
      }

      @Override
      public void doWithFile(YContentFile yfile) {
        if (isFileAcceptable(yfile)) {
          result.setValue(true);
        }
      }
      
    });
    
    return result.getValue();
  }
}

代码示例来源:origin: org.neo4j/neo4j-kernel

/**
 * @return true if instantiated tree needs to be rebuilt.
 */
private boolean instantiateTree() throws IOException
{
  monitors.addMonitorListener( treeMonitor() );
  GBPTree.Monitor monitor = monitors.newMonitor( GBPTree.Monitor.class );
  MutableBoolean isRebuilding = new MutableBoolean();
  Header.Reader readRebuilding =
      headerData -> isRebuilding.setValue( headerData.get() == NEEDS_REBUILDING );
  index = new GBPTree<>( pageCache, storeFile, new LabelScanLayout(), pageSize, monitor, readRebuilding,
      needsRebuildingWriter, recoveryCleanupWorkCollector );
  return isRebuilding.getValue();
}

代码示例来源:origin: kframework/k

if (isRecursive.getValue()) {
  conn = "let rec ";
  isLetRec = true;

代码示例来源:origin: kframework/k

if (!isProtecting.getValue()) {
  nonProtectingSubsorts.add(subsort);

相关文章