Process mockProcess = createMockProcess("test data");
        JobProcess jobProcess = new JobProcess(mockProcess);

        InputStreamThread thread = jobProcess.getInputStreamThread();

        assertNotNull(thread);
        assertEquals("InputStreamThread", thread.getName());
    }

    @Test
    public void test_constructor_withZeroBufferSize() throws IOException {

import org.codelibs.fess.helper.SystemHelper;
import org.codelibs.fess.mylasta.direction.FessConfig;
import org.codelibs.fess.unit.UnitFessTestCase;
import org.codelibs.fess.util.ComponentUtil;
import org.codelibs.fess.util.InputStreamThread;
import org.codelibs.fess.util.JobProcess;
import org.junit.jupiter.api.Test;
import org.junit.jupiter.api.TestInfo;

import jakarta.servlet.ServletContext;

        @Override
        public InputStreamThread getInputStreamThread() {
            return new MockInputStreamThread(output);
        }

        @Override
        public Process getProcess() {
            return new MockProcess(exitValue);
        }
    }

    // Mock InputStreamThread implementation
    private class MockInputStreamThread extends InputStreamThread {
        private final String output;

import org.codelibs.fess.helper.ProcessHelper;
import org.codelibs.fess.mylasta.direction.FessConfig;
import org.codelibs.fess.unit.UnitFessTestCase;
import org.codelibs.fess.util.ComponentUtil;
import org.codelibs.fess.util.InputStreamThread;
import org.codelibs.fess.util.JobProcess;
import org.junit.jupiter.api.Test;
import org.junit.jupiter.api.TestInfo;

import jakarta.servlet.ServletContext;

public class PythonJobTest extends UnitFessTestCase {