Try - Code Search

guava-gwt/src-super/com/google/common/util/concurrent/super/com/google/common/util/concurrent/InterruptibleTask.java

abstract class InterruptibleTask<T extends @Nullable Object> implements Runnable {

  @Override
  public void run() {
    T result = null;
    Throwable error = null;
    if (isDone()) {
      return;
    }
    try {
      result = runInterruptibly();
    } catch (Throwable t) {
      error = t;
    }
    if (error == null) {
      // The cast is safe because of the `run` and `error` checks.

Created: Fri Apr 03 12:43:13 GMT 2026

- Last Modified: Sun Dec 22 03:38:46 GMT 2024

- 1.6K bytes

- Click Count (0)

github.com/codelibs/corelib

src/main/java/org/codelibs/core/misc/DynamicProperties.java

        FileOutputStream fos = null;
        try {
            fos = new FileOutputStream(propertiesFile);
            properties.store(fos, propertiesFile.getName());
        } catch (final IOException e) {
            throw new FileAccessException("ECL0112", new Object[] { propertiesFile.getAbsolutePath() }, e);
        } finally {
            if (fos != null) {
                try {
                    fos.close();

Created: Fri Apr 03 20:58:12 GMT 2026

- Last Modified: Sat Jul 05 00:11:05 GMT 2025

- 13.1K bytes

- Click Count (0)

github.com/codelibs/jcifs

src/test/java/jcifs/util/SecureKeyManagerTest.java

        assertEquals(0, keyManager.getKeyCount(), "Should have no keys after close");
    }

    @Test
    public void testAutoCloseable() throws Exception {
        try (SecureKeyManager manager = new SecureKeyManager()) {
            manager.storeSessionKey("auto-session", testKey, "AES");
            assertTrue(manager.hasSessionKey("auto-session"), "Key should exist");
        }

Created: Sun Apr 05 00:10:12 GMT 2026

- Last Modified: Sat Aug 30 05:58:03 GMT 2025

- 14.2K bytes

- Click Count (0)

github.com/apache/maven

compat/maven-plugin-api/src/main/java/org/apache/maven/plugin/descriptor/PluginDescriptor.java

    }

    public Map<String, Lifecycle> getLifecycleMappings() throws IOException, XMLStreamException {
        if (lifecycleMappings == null) {
            LifecycleConfiguration lifecycleConfiguration;

            try (InputStream input = getDescriptorStream(LIFECYCLE_DESCRIPTOR)) {
                lifecycleConfiguration = new LifecycleStaxReader().read(input);
            }

            lifecycleMappings = new HashMap<>();

Created: Sun Apr 05 03:35:12 GMT 2026

- Last Modified: Fri Jun 06 14:28:57 GMT 2025

- 16.2K bytes

- Click Count (0)

github.com/codelibs/fess

src/main/java/org/codelibs/fess/app/service/CrawlingInfoService.java

        final DateFormat formatter = new SimpleDateFormat(CoreLibConstants.DATE_FORMAT_ISO_8601_EXTEND);
        try {
            List<String> list;
            csvReader.readValues(); // ignore header
            while ((list = csvReader.readValues()) != null) {
                try {
                    final String sessionId = list.get(0);

Created: Tue Mar 31 13:07:34 GMT 2026

- Last Modified: Thu Jul 17 08:28:31 GMT 2025

- 19.9K bytes

- Click Count (0)

github.com/codelibs/fess

src/main/webapp/WEB-INF/view/error/badRequest.jsp

<%@page pageEncoding="UTF-8" contentType="text/html; charset=UTF-8"%><!DOCTYPE html>
<% try{ %>
${fe:html(true)}
<head>
<meta charset="utf-8">
<meta name="viewport" content="width=device-width, initial-scale=1">
<meta http-equiv="X-UA-Compatible" content="IE=edge">
<title><la:message key="labels.system_error_title" /></title>
<link href="${fe:url('/css/bootstrap.min.css')}" rel="stylesheet"
	type="text/css" />

Created: Tue Mar 31 13:07:34 GMT 2026

- Last Modified: Thu Nov 13 05:54:52 GMT 2025

- 1.5K bytes

- Click Count (0)

github.com/square/okhttp

okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/IsProbablyUtf8.kt

 * signatures.
 *
 * @param codePointLimit the number of code points to read in order to make a decision.
 */
internal fun BufferedSource.isProbablyUtf8(codePointLimit: Long = Long.MAX_VALUE): Boolean {
  try {
    val peek = peek()
    for (i in 0 until codePointLimit) {
      if (peek.exhausted()) {
        break
      }
      val codePoint = peek.readUtf8CodePoint()

Created: Fri Apr 03 11:42:14 GMT 2026

- Last Modified: Mon Oct 06 22:47:06 GMT 2025

- 1.4K bytes

- Click Count (0)

github.com/square/okhttp

samples/guide/src/main/java/okhttp3/recipes/ConfigureTimeouts.java

  }

  public void run() throws Exception {
    Request request = new Request.Builder()
        .url("http://httpbin.org/delay/2") // This URL is served with a 2 second delay.
        .build();

    try (Response response = client.newCall(request).execute()) {
      System.out.println("Response completed: " + response);
    }
  }

  public static void main(String... args) throws Exception {

Created: Fri Apr 03 11:42:14 GMT 2026

- Last Modified: Sat Sep 28 18:00:26 GMT 2019

- 1.5K bytes

- Click Count (0)

github.com/square/okhttp

samples/guide/src/main/java/okhttp3/recipes/SynchronousGet.java

  public void run() throws Exception {
    Request request = new Request.Builder()
        .url("https://publicobject.com/helloworld.txt")
        .build();

    try (Response response = client.newCall(request).execute()) {
      if (!response.isSuccessful()) throw new IOException("Unexpected code " + response);

      Headers responseHeaders = response.headers();

Created: Fri Apr 03 11:42:14 GMT 2026

- Last Modified: Sun May 22 01:29:42 GMT 2016

- 1.5K bytes

- Click Count (0)

github.com/minio/minio

helm/minio/templates/_helper_custom_command.txt

    $MC_COMMAND ;
    STATUS=$? ;
  done ;
  set -e ; # reset `e` as active
  return 0
}

# runCommand ($@)
# Run custom mc command
runCommand() {
  ${MC} "$@"
  return $?
}

# Try connecting to MinIO instance
{{- if .Values.tls.enabled }}
scheme=https
{{- else }}
scheme=http
{{- end }}
connectToMinio $scheme

{{ if .Values.customCommands }}
# Run custom commands

Created: Sun Apr 05 19:28:12 GMT 2026

- Last Modified: Sat Feb 19 20:34:14 GMT 2022

- 1.4K bytes

- Click Count (0)

Search Options