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

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

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

MutableBoolean.setTrue介绍

[英]Sets the value to true.
[中]将该值设置为true。

代码示例

代码示例来源：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: kiegroup/jbpm

@Override
  public void afterNodeLeft(ProcessNodeLeftEvent event) {
    // BoundaryEventNodeInstance
    if(signal.equals(event.getNodeInstance().getNodeName())) {
      eventAfterNodeLeftTriggered.setTrue();
    }
  }
});

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

@Override
  public void visitNodePropertyChanges( long id, Iterator<StorageProperty> added, Iterator<StorageProperty> changed, IntIterable removed )
  {
    propertiesChecked.setTrue();
    assertEquals( 1, id );
    assertFalse( changed.hasNext() );
    assertTrue( removed.isEmpty() );
    assertEquals( 1, Iterators.count( added, Predicates.alwaysTrue() ) );
  }
} );

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

@Override
public void visitNodeLabelChanges( long id, LongSet added, LongSet removed )
{
  labelsChecked.setTrue();
  assertEquals( 1, id );
  assertEquals( 1, added.size() );
  assertTrue( added.contains( 5 ) );
  assertTrue( removed.isEmpty() );
}

代码示例来源：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

triggered.setTrue();

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

triggered.setTrue();
  return new Root( cursor.getCurrentPageId(), TreeNode.generation( cursor ) );
};

代码示例来源：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: us.ihmc/robot-environment-awareness

@Override
public void doActionOnNeighbor(NormalOcTreeNode node)
{
 if (otherRegion.contains(node))
   foundNeighborFromOtherRegion.setTrue();
}

代码示例来源：origin: CodisLabs/nedis

@Override
  public boolean process(byte value) throws Exception {
    if (value == '\n') {
      if ((byte) buffer.charAt(buffer.length() - 1) != '\r') {
        throw new ProtocolException("Response is not ended by CRLF");
      } else {
        buffer.setLength(buffer.length() - 1);
        reachCRLF.setTrue();
        return false;
      }
    } else {
      buffer.append((char) value);
      return true;
    }
  }
}));

代码示例来源：origin: com.github.endoscope/endoscope-storage-jdbc

protected List<GroupEntity> tailAfter(List<GroupEntity> groups, String lastGroupId) {
  if( lastGroupId == null ){
    return groups;
  }
  List<GroupEntity> nextGroups = new ArrayList();
  final MutableBoolean found = new MutableBoolean(false);
  groups.forEach( g -> {
    if(found.isTrue()) {
      nextGroups.add(g);
    } else if (lastGroupId.equals(g.getId()) ) {
      found.setTrue();
    }
  });
  return nextGroups;
}

代码示例来源：origin: us.ihmc/IHMCHumanoidRobotics

/** {@inheritDoc} */
@Override
public void compile(GoHomeCommand other)
{
 trajectoryTime = other.trajectoryTime;
 for (BodyPart bodyPart : BodyPart.values)
 {
   if (bodyPart.isRobotSideNeeded())
   {
    for (RobotSide robotSide : RobotSide.values)
    {
      if (other.getRequest(robotSide, bodyPart))
       sideDependentBodyPartRequestMap.get(robotSide).get(bodyPart).setTrue();
    }
   }
   else if (other.getRequest(bodyPart))
   {
      otherBodyPartRequestMap.get(bodyPart).setTrue();
   }
 }
}

代码示例来源：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: us.ihmc/IHMCHumanoidRobotics

/** {@inheritDoc} */
@Override
public void set(GoHomeMessage message)
{
 clear();
 trajectoryTime = message.getTrajectoryTime();
 BodyPart bodyPart = message.getBodyPart();
 if (bodyPart.isRobotSideNeeded())
 {
   RobotSide robotSide = message.getRobotSide();
   sideDependentBodyPartRequestMap.get(robotSide).get(bodyPart).setTrue();
 }
 else
 {
   otherBodyPartRequestMap.get(bodyPart).setTrue();
 }
}

代码示例来源：origin: CodisLabs/nedis

@Override
  public boolean process(byte value) throws Exception {
    if (value == '\r') {
      reachCR.setTrue();
      return false;
    } else {
      if (value >= '0' && value <= '9') {
        l.setValue(l.longValue() * 10 + toDigit(value));
      } else {
        throw new ProtocolException("Response is not ended by CRLF");
      }
      return true;
    }
  }
}));

代码示例来源：origin: org.nuxeo.elasticsearch/nuxeo-elasticsearch-core

@Override
public void afterBulk(long executionId, BulkRequest request, BulkResponse response) {
  if (log.isDebugEnabled()) {
    log.debug(String.format("After bulk: %s, actions: %d, status: %s", executionId, request.numberOfActions(),
        response.status()));
  }
  if (!response.hasFailures()) {
    return;
  }
  MutableBoolean inError = new MutableBoolean(false);
  Arrays.stream(response.getItems()).filter(BulkItemResponse::isFailed).forEach(item -> {
    if (item.getFailure().getStatus() != RestStatus.CONFLICT) {
      log.warn("Failure in bulk indexing: " + item.getFailureMessage());
      inError.setTrue();
    } else if (log.isDebugEnabled()) {
      log.debug("Skipping version conflict: " + item.getFailureMessage());
    }
  });
  if (inError.isTrue()) {
    log.error(String.format("Elasticsearch bulk %s returns with failures: %s", executionId,
        response.buildFailureMessage()));
    if (!continueOnFailure) {
      abort = true;
    }
  }
}

代码示例来源：origin: apache/asterixdb

@Override
public void fail() throws HyracksDataException {
  hasFailed.setTrue();
  HyracksDataException hde = null;
  for (int i = 0; i < numberOfNonMaterializedOutputs; i++) {
    if (isOpen[i]) {
      try {
        writers[i].fail();
      } catch (Throwable th) {
        if (hde == null) {
          hde = HyracksDataException.create(th);
        } else {
          hde.addSuppressed(th);
        }
      }
    }
  }
  if (hde != null) {
    throw hde;
  }
}

代码示例来源：origin: org.wso2.carbon.auth/org.wso2.carbon.auth.oauth

private Scope getScope(String clientId, AuthorizationCodeGrant request, AccessTokenContext context,
              MutableBoolean haltExecution) {
    String authCode = request.getAuthorizationCode().getValue();
    URI redirectionURI = request.getRedirectionURI();

    try {
      String scope = oauthDAO.getScopeForAuthCode(authCode, clientId, redirectionURI);

      if (scope != null) {
        return new Scope(scope);
      } else {
        context.setErrorObject(OAuth2Error.INVALID_REQUEST);
        haltExecution.setTrue();
      }
    } catch (OAuthDAOException e) {
      log.error("Error while validating query parameters", e);
      context.setErrorObject(OAuth2Error.SERVER_ERROR);
      haltExecution.setTrue();
    }

    return null;
  }
}

代码示例来源：origin: org.nuxeo.ecm.core/nuxeo-core

@Override
public boolean validate(Object value, Object context) {
  MutableBoolean validated = new MutableBoolean();
  resolve(value, context, (session, docRef) -> {
    if (session.exists(docRef)) {
      validated.setTrue();
    }
  });
  return validated.isTrue();
}

代码示例来源：origin: org.jbpm/jbpm-bpmn2

@Override
  public void afterNodeLeft(ProcessNodeLeftEvent event) {
    // BoundaryEventNodeInstance
    if(signal.equals(event.getNodeInstance().getNodeName())) {
      eventAfterNodeLeftTriggered.setTrue();
    }
  }
});

内容来源于网络，如有侵权，请联系作者删除！

MutableBoolean

相关文章

    查看更多
    微信公众号

    热门标签

    更多
    JavaquerypythonNode开发语言requestUtil数据库Table后端算法LoggerMessageElementParser

    最新文章

    更多
    • 蜀ICP备13028337号-1 大数据知识库 https://www.saoniuhuo.com © All rights reserved
    • 本站内容来源互联网,如果侵犯您的权益请联系我们删除, 联系方式：448109455@qq.com